partition

package
v1.3.0 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PartitionedQueue

type PartitionedQueue struct {
	config.CommonFields
	Partition int `mapstructure:"partition"` // The total partition count.
	// contains filtered or unexported fields
}

func NewPartitionQueue

func NewPartitionQueue(c plugin.Config) *PartitionedQueue

func (*PartitionedQueue) Ack

func (p *PartitionedQueue) Ack(lastOffset *event.Offset)

func (*PartitionedQueue) Close

func (p *PartitionedQueue) Close() error

func (*PartitionedQueue) DefaultConfig

func (p *PartitionedQueue) DefaultConfig() string

func (*PartitionedQueue) Dequeue

func (p *PartitionedQueue) Dequeue(partition int) (*api.SequenceEvent, error)

func (*PartitionedQueue) Description

func (p *PartitionedQueue) Description() string

func (*PartitionedQueue) Enqueue

func (p *PartitionedQueue) Enqueue(e *v1.SniffData) error

func (*PartitionedQueue) Initialize

func (p *PartitionedQueue) Initialize() error

func (*PartitionedQueue) Name

func (p *PartitionedQueue) Name() string

func (*PartitionedQueue) ShowName

func (p *PartitionedQueue) ShowName() string

func (*PartitionedQueue) TotalPartitionCount

func (p *PartitionedQueue) TotalPartitionCount() int

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL