stateless

package
v0.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 2, 2023 License: GPL-3.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrorRetryAttempt = errors.New("retry all attempts failed")

Functions

func TopicMissingError 

func TopicMissingError(topic string) error

func WithBatchIterateFunctionNextFunction 

func WithBatchIterateFunctionNextFunction(next SingleFunction) runtime.Configuration[*ProducerBatchIterateFunction]

func WithBatchIterateFunctionProducer 

func WithBatchIterateFunctionProducer(producer runtime.Producer) runtime.Configuration[*ProducerBatchIterateFunction]

func WithBatchProducerNextFunction 

func WithBatchProducerNextFunction(next BatchFunction) runtime.Configuration[*BatchProducer]

func WithBatchProducerRuntime 

func WithBatchProducerRuntime(producer runtime.Producer) runtime.Configuration[*BatchProducer]

configuration

func WithBatchRetryNextFunction 

func WithBatchRetryNextFunction(next BatchFunction) runtime.Configuration[*BatchRetry]

func WithBatchRetryPrometheus 

func WithBatchRetryPrometheus() runtime.Configuration[*SingleRetry]

func WithBatchRetryRuntime 

func WithBatchRetryRuntime(retry *runtime_retry.Retry) runtime.Configuration[*BatchRetry]

configurations

func WithSingleProducerNextFunction 

func WithSingleProducerNextFunction(next SingleFunction) runtime.Configuration[*SingleProducer]

func WithSingleProducerPrometheus 

func WithSingleProducerPrometheus() runtime.Configuration[*SingleProducer]

func WithSingleProducerRuntime 

func WithSingleProducerRuntime(producer runtime.Producer) runtime.Configuration[*SingleProducer]

configurations

func WithSingleRetryNextFunction 

func WithSingleRetryNextFunction(next SingleFunction) runtime.Configuration[*SingleRetry]

func WithSingleRetryPrometheus 

func WithSingleRetryPrometheus() runtime.Configuration[*SingleRetry]

func WithSingleRetryRuntime 

func WithSingleRetryRuntime(retry *runtime_retry.Retry) runtime.Configuration[*SingleRetry]

configurations

func WithSingleTopicSwitchStatelessSingleFunction 

func WithSingleTopicSwitchStatelessSingleFunction(topic string, f SingleFunction) runtime.Configuration[*SingleTopicSwitch]

configuration

Types

type BatchFunction 

type BatchFunction func(context.Context, []message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

func NewBatchRetry 

func NewBatchRetry(configurations ...runtime.Configuration[*BatchRetry]) BatchFunction

constructor

func NewProducerBatchFunction 

func NewProducerBatchFunction(configurations ...runtime.Configuration[*BatchProducer]) BatchFunction

constructor

func NewProducerBatchIterateFunction 

func NewProducerBatchIterateFunction(configurations ...runtime.Configuration[*ProducerBatchIterateFunction]) BatchFunction

constructor

type BatchProducer 

type BatchProducer struct {
	// contains filtered or unexported fields
}

implementation

func (BatchProducer) Apply 

func (r BatchProducer) Apply(c context.Context, m []message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type BatchRetry 

type BatchRetry struct {
	// contains filtered or unexported fields
}

implementation

func (*BatchRetry) Apply 

func (r *BatchRetry) Apply(c context.Context, m []message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type OneToOneExplodeFunction added in v0.0.5 

type OneToOneExplodeFunction[IK any, IV any, OK any, OV any] func(context.Context, message.Message[IK, IV]) ([]message.Message[OK, OV], error)

type OneToOneFunction 

type OneToOneFunction[IK any, IV any, OK any, OV any] func(context.Context, message.Message[IK, IV]) (*message.Message[OK, OV], error)

type OneToTwoFunction 

type OneToTwoFunction[IK any, IV any, OK1 any, OV1 any, OK2 any, OV2 any] func(context.Context, message.Message[IK, IV]) (*message.Message[OK1, OV1], *message.Message[OK2, OV2], error)

type ProducerBatchIterateFunction 

type ProducerBatchIterateFunction struct {
	// contains filtered or unexported fields
}

implementation

func (*ProducerBatchIterateFunction) Apply 

func (r *ProducerBatchIterateFunction) Apply(c context.Context, ms []message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type SingleFunction 

type SingleFunction func(context.Context, message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

func ConvertOneToOne 

func ConvertOneToOne[IK any, IV any, OK any, OV any](
	source OneToOneFunction[IK, IV, OK, OV],
	ik format.Format[IK],
	iv format.Format[IV],
	ok format.Format[OK],
	ov format.Format[OV],
) SingleFunction

func ConvertOneToOneExplode added in v0.0.5 

func ConvertOneToOneExplode[IK any, IV any, OK any, OV any](
	source OneToOneExplodeFunction[IK, IV, OK, OV],
	ik format.Format[IK],
	iv format.Format[IV],
	ok format.Format[OK],
	ov format.Format[OV],
) SingleFunction

func ConvertOneToTwo 

func ConvertOneToTwo[IK any, IV any, OK1 any, OV1 any, OK2 any, OV2 any](
	source OneToTwoFunction[IK, IV, OK1, OV1, OK2, OV2],
	ik format.Format[IK],
	iv format.Format[IV],
	ok1 format.Format[OK1],
	ov1 format.Format[OV1],
	ok2 format.Format[OK2],
	ov2 format.Format[OV2],
) SingleFunction

func NewSingleProducer 

func NewSingleProducer(configurations ...runtime.Configuration[*SingleProducer]) SingleFunction

constructor

func NewSingleRetry 

func NewSingleRetry(configurations ...runtime.Configuration[*SingleRetry]) SingleFunction

constructor

func NewSingleTopicSwitch 

func NewSingleTopicSwitch(configurations ...runtime.Configuration[*SingleTopicSwitch]) SingleFunction

constructor

type SingleProducer 

type SingleProducer struct {
	// contains filtered or unexported fields
}

implementation

func (SingleProducer) Apply 

func (r SingleProducer) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type SingleRetry 

type SingleRetry struct {
	// contains filtered or unexported fields
}

implementation

func (*SingleRetry) Apply 

func (r *SingleRetry) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type SingleTopicSwitch 

type SingleTopicSwitch struct {
	// contains filtered or unexported fields
}

implementation

func (*SingleTopicSwitch) Apply 

func (r *SingleTopicSwitch) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.