consumer

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFactory added in v0.2.0 

func NewFactory(
	bootstrapServers []string,
	groupID string,
	topic string,
	partition mo.Either[int, string],
	offset int64,
	fromDateTime time.Time,
	wireFormat wire.Format,
	protoFile string,
	messageType string,
	includePaths []string,
) *factory

Types

type ClosableConsumer added in v0.2.0 

type ClosableConsumer interface {
	io.Closer
	Consume(ctx context.Context, decoder WireDecoder) <-chan Result
}

type GroupConsumer added in v0.1.4 

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

func NewGroupConsumer added in v0.1.4 

func NewGroupConsumer(opts GroupConsumerOpts) (*GroupConsumer, error)

func (*GroupConsumer) Close added in v0.1.4 

func (gc *GroupConsumer) Close() error

func (*GroupConsumer) Consume added in v0.1.4 

func (gc *GroupConsumer) Consume(ctx context.Context, decoder WireDecoder) <-chan Result

type GroupConsumerOpts added in v0.1.4 

type GroupConsumerOpts struct {
	BootstrapServers []string `validate:"required"`
	GroupID          string   `validate:"required"`
	Topic            string   `validate:"required"`
}

type MultiPartitionConsumer added in v0.2.0 

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

func NewMultiPartitionConsumer added in v0.2.0 

func NewMultiPartitionConsumer(ctx context.Context, opts MultiPartitionConsumerOpts) (*MultiPartitionConsumer, error)

func (*MultiPartitionConsumer) Close added in v0.2.0 

func (mpc *MultiPartitionConsumer) Close() error

func (*MultiPartitionConsumer) Consume added in v0.2.0 

func (mpc *MultiPartitionConsumer) Consume(ctx context.Context, decoder WireDecoder) <-chan Result

type MultiPartitionConsumerOpts added in v0.2.0 

type MultiPartitionConsumerOpts struct {
	BootstrapServers []string `validate:"required"`
	Topic            string   `validate:"required"`
	Offset           int64
	FromDateTime     time.Time
}

func (*MultiPartitionConsumerOpts) Paritions added in v0.2.0 

func (opts *MultiPartitionConsumerOpts) Paritions(ctx context.Context) ([]kafka.Partition, error)

type PartitionConsumer added in v0.1.4 

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

func NewPartitionConsumer added in v0.1.4 

func NewPartitionConsumer(ctx context.Context, opts PartitionConsumerOpts) (*PartitionConsumer, error)

func (*PartitionConsumer) Close added in v0.1.4 

func (pc *PartitionConsumer) Close() error

func (*PartitionConsumer) Consume added in v0.1.4 

func (pc *PartitionConsumer) Consume(ctx context.Context, decoder WireDecoder) <-chan Result

type PartitionConsumerOpts added in v0.1.4 

type PartitionConsumerOpts struct {
	BootstrapServers []string `validate:"required"`
	Topic            string   `validate:"required"`
	Partition        int      `validate:"gte=0"`
	Offset           int64
	FromDateTime     time.Time
}

type Result added in v0.1.4 

type Result struct {
	Message string
	Err     error
}

type WireDecoder added in v0.1.4 

type WireDecoder interface {
	Decode([]byte) (string, 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.
JackTT - Gopher 🇻🇳