Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddTransientCentrifugeStreamBatcher ¶
func AddTransientCentrifugeStreamBatcher(cb di.ContainerBuilder)
func IsCanceled ¶
func NewBatchManagement ¶
func NewBatchManagement(config *batchManagementConfig) *batchManagement
func NewPublicationBatcher ¶
func NewPublicationBatcher(batchSize int32) *publicationBatcher
Types ¶
type PublicationPackage ¶
type PublicationPackage struct { StreamPosition *centrifuge.StreamPosition // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.