Versions in this module Expand all Collapse all v4 v4.27.1 May 31, 2024 v4.27.0 May 31, 2024 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 AddKnownCompressionAlgorithm(name string, a KnownCompressionAlgorithm) struct + func CacheOutputSpec() *service.ConfigSpec + func CommonRetryBackOffCtorFromParsed(pConf *service.ParsedConfig) (ctor func() backoff.BackOff, err error) + func CommonRetryBackOffFields(defaultMaxRetries int, defaultInitInterval string, defaultMaxInterval string, ...) []*service.ConfigField + func CompressionAlgsList() (v []string) + func DecompressionAlgsList() (v []string) + 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) Close(ctx context.Context) error + func (b *Branch) ProcessBatch(ctx context.Context, batch message.Batch) ([]message.Batch, error) + type CacheWriter struct + func NewCacheWriter(conf *service.ParsedConfig, mgr bundle.NewManagement) (*CacheWriter, error) + 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) (err error) + 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 CompressFunc func(level int, b []byte) ([]byte, error) + type CompressWriter func(level int, w io.Writer) (io.Writer, error) + type DecompressFunc func(b []byte) ([]byte, error) + type DecompressReader func(r io.Reader) (io.Reader, error) + type KnownCompressionAlgorithm struct + CompressFunc CompressFunc + CompressWriter CompressWriter + DecompressFunc DecompressFunc + DecompressReader DecompressReader + type SyncResponseWriter struct + 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 struct + func NewWorkflow(conf *service.ParsedConfig, mgr bundle.NewManagement) (*Workflow, error) + func (w *Workflow) Close(ctx context.Context) error + func (w *Workflow) Flow() [][]string + func (w *Workflow) ProcessBatch(ctx context.Context, msg message.Batch) ([]message.Batch, error)
Go to main page