pure

Mar 1, 2024

Changes in this version

+ func AddKnownCompressionAlgorithm(name string, a KnownCompressionAlgorithm) struct

+ func CacheOutputSpec() *service.ConfigSpec

+ func CompressionAlgsList() (v []string)

+ func DecompressionAlgsList() (v []string)

+ type CombinedReadCloser struct

+ Primary io.Reader

+ Source io.Reader

+ func (c *CombinedReadCloser) Close() error

+ func (c *CombinedReadCloser) Read(b []byte) (int, error)

+ type CombinedWriteCloser struct

+ Primary io.Writer

+ Sink io.Writer

+ func (c *CombinedWriteCloser) Close() error

+ func (c *CombinedWriteCloser) Write(b []byte) (int, error)

+ type CompressWriter func(level int, w io.Writer) (io.Writer, error)

+ type DecompressReader func(r io.Reader) (io.Reader, error)

+ type KnownCompressionAlgorithm struct

+ CompressFunc CompressFunc

+ CompressWriter CompressWriter

+ DecompressFunc DecompressFunc

+ DecompressReader DecompressReader

May 28, 2023

Changes in this version

+ func CommonRetryBackOffCtorFromParsed(pConf *service.ParsedConfig) (ctor func() backoff.BackOff, err error)

+ func CommonRetryBackOffFields(defaultMaxRetries int, defaultInitInterval string, defaultMaxInterval string, ...) []*service.ConfigField

Feb 20, 2023

Changes in this version

+ func AddCompressFunc(name string, fn CompressFunc) struct

+ func AddDecompressFunc(name string, fn DecompressFunc) struct

+ type CompressFunc func(level int, bytes []byte) ([]byte, error)

+ type DecompressFunc func(bytes []byte) ([]byte, error)

Aug 31, 2022

Changes in this version

type Branch

+ func (b *Branch) Close(ctx context.Context) error

+ func (b *Branch) ProcessBatch(ctx context.Context, batch message.Batch) ([]message.Batch, error)

type CacheWriter

+ func (c *CacheWriter) Close(context.Context) error

+ func (c *CacheWriter) Connect(ctx context.Context) error

+ func (c *CacheWriter) WriteBatch(ctx context.Context, msg message.Batch) error

type SyncResponseWriter

+ func (s SyncResponseWriter) Close(context.Context) error

+ func (s SyncResponseWriter) Connect(ctx context.Context) error

+ func (s SyncResponseWriter) WriteBatch(ctx context.Context, msg message.Batch) error

type Workflow

+ func (w *Workflow) Close(ctx context.Context) error

+ func (w *Workflow) ProcessBatch(ctx context.Context, msg message.Batch) ([]message.Batch, error)

May 11, 2022

Changes in this version

+ var ErrBrokerNoInputs = errors.New("attempting to create broker input type with no inputs")

+ var ErrBrokerNoOutputs = errors.New("attempting to create broker output type with no outputs")

+ var ErrSwitchNoCasesMatched = errors.New("no switch cases were matched by message")

+ var ErrSwitchNoConditionMet = errors.New("no switch output conditions were met by message")

+ var ErrSwitchNoOutputs = errors.New("attempting to create switch with fewer than 2 cases")

+ func RetryOutputIndefinitely(mgr bundle.NewManagement, wrapped output.Streamed) (output.Streamed, error)

+ func SwitchReorderFromGroup(group *message.SortGroup, parts []*message.Part)

+ type Branch struct

+ func (b *Branch) CloseAsync()

+ func (b *Branch) ProcessMessage(msg *message.Batch) ([]*message.Batch, error)

+ func (b *Branch) WaitForClose(timeout time.Duration) error

+ type CacheWriter struct

+ func NewCacheWriter(conf output.CacheConfig, mgr bundle.NewManagement, log log.Modular) (*CacheWriter, error)

+ func (c *CacheWriter) CloseAsync()

+ func (c *CacheWriter) ConnectWithContext(ctx context.Context) error

+ func (c *CacheWriter) WaitForClose(time.Duration) error

+ func (c *CacheWriter) WriteWithContext(ctx context.Context, msg *message.Batch) error

+ type SyncResponseWriter struct

+ func (s SyncResponseWriter) CloseAsync()

+ func (s SyncResponseWriter) ConnectWithContext(ctx context.Context) error

+ func (s SyncResponseWriter) WaitForClose(time.Duration) error

+ func (s SyncResponseWriter) WriteWithContext(ctx context.Context, msg *message.Batch) error

+ type Workflow struct

+ func NewWorkflow(conf processor.WorkflowConfig, mgr bundle.NewManagement) (*Workflow, error)

+ func (w *Workflow) CloseAsync()

+ func (w *Workflow) Flow() [][]string

+ func (w *Workflow) ProcessMessage(msg *message.Batch) ([]*message.Batch, error)

+ func (w *Workflow) WaitForClose(timeout time.Duration) error