batcher

Documentation

Index

• func AddTransientCentrifugeStreamBatcher(cb di.ContainerBuilder)
• func IsCanceled(ctx context.Context) bool
• func NewBatchManagement(config *batchManagementConfig) *batchManagement
• func NewPublicationBatcher(batchSize int32) *publicationBatcher
• func StringPtr(s string) *string
• type PublicationPackage

Functions

func AddTransientCentrifugeStreamBatcher

func AddTransientCentrifugeStreamBatcher(cb di.ContainerBuilder)

func IsCanceled

func IsCanceled(ctx context.Context) bool

func NewBatchManagement

func NewBatchManagement(config *batchManagementConfig) *batchManagement

func NewPublicationBatcher

func NewPublicationBatcher(batchSize int32) *publicationBatcher

func StringPtr

func StringPtr(s string) *string

Types

type PublicationPackage

type PublicationPackage struct {
	StreamPosition *centrifuge.StreamPosition
	// contains filtered or unexported fields
}