chanjet

package module

v1.0.4 Latest Latest Go to latest Published: Jun 7, 2025 License: Apache-2.0 Imports: 1 Imported by: 0

Details

High-Performance double-buffered channel using Go slice, buffer pool and zero-copy.

View Source

const (
	WritingStatus = iota
	PendingStatus
	ClosedStatus
)

View Source

const (
	SizeWeight   float64 = 0.6
	TimeWeight   float64 = 0.4
	FullCapacity float64 = 0.85
)

View Source

const MinBufferSize = 1

View Source

const Unknown = "unknown"

This section is empty.

This section is empty.

type CollectorType int

const (
	PrometheusCollector CollectorType = iota
	OpenTelemetryCollector
)

func (c CollectorType) String() string

func (c CollectorType) Validate() bool

type DefaultStrategy struct{}

func (d *DefaultStrategy) NeedSwitch(currentCount, bufferSize int32, elapsed, interval time.Duration) bool

type OperationType int

const (
	MetricsIncOp OperationType = iota
	MetricsDecOp
)

type ReadMode int

const (
	SafeRead ReadMode = iota + 1
	ZeroCopyRead
)

func (m ReadMode) String() string

func (m ReadMode) Validate() bool

type SizeOnlyStrategy struct{}

func (s *SizeOnlyStrategy) NeedSwitch(currentCount, bufferSize int32, _, _ time.Duration) bool

type SwitchStatus int

const (
	SwitchSuccess SwitchStatus = iota
	SwitchFailure
	SwitchSkip
)

func (s SwitchStatus) String() string

type SwitchStrategy interface {
	NeedSwitch(currentCount, bufferSize int32, elapsed, interval time.Duration) bool
}

func NewDefaultStrategy() SwitchStrategy

func NewSizeOnlyStrategy() SwitchStrategy

func NewTimeWindowOnlyStrategy() SwitchStrategy

type TimeWindowOnlyStrategy struct{}

func (s *TimeWindowOnlyStrategy) NeedSwitch(_, _ int32, elapsed, interval time.Duration) bool