sources

Documentation

Index

• type ConstSource
  • func NewConstSource(value string, flushDuration time.Duration, maxBatchSize int, ...) *ConstSource
  • func (s *ConstSource) Close() error
  • func (s *ConstSource) Name() string
  • func (s *ConstSource) Open(ctx context.Context) error

Types

type ConstSource

type ConstSource struct {
	Value         string
	FlushDuration time.Duration
	MaxBatchSize  int
	// contains filtered or unexported fields
}

func NewConstSource

func NewConstSource(value string, flushDuration time.Duration, maxBatchSize int, workerGenerator engine.WorkerCreatorFunc) *ConstSource

TODO more variety of source values

func (*ConstSource) Close

func (s *ConstSource) Close() error

func (*ConstSource) Name

func (s *ConstSource) Name() string

func (*ConstSource) Open

func (s *ConstSource) Open(ctx context.Context) error