zk

Documentation

Index

• Variables
• type Consumer
  • func NewChildConsumer(logger log.Logger, path string, options ...ConsumerOption) (*Consumer, error)
  • func NewConsumer(logger log.Logger, path string, options ...ConsumerOption) (*Consumer, error)
  • func (c *Consumer) Open() error
• type ConsumerOption
  • func WithDelayOnErrConsumerOption(d DelayOnErr) ConsumerOption
  • func WithEndpointConsumerOption(end endpoint.Endpoint) ConsumerOption
  • func WithReconnectOnErrConsumerOption(r ReconnectOnErr) ConsumerOption
  • func WithZkDriver(d driver.Driver) ConsumerOption
• type Decoder
• type DelayOnErr
• type ErrorHandler
• type ReconnectOnErr

Variables

var (
	ErrCreatingConsumer = errors.New("error creating consumer")
)

consumer Errors

Types

type Consumer

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

func NewChildConsumer

func NewChildConsumer(
	logger log.Logger,
	path string,
	options ...ConsumerOption,
) (*Consumer, error)

func NewConsumer

func NewConsumer(
	logger log.Logger,
	path string,
	options ...ConsumerOption,
) (*Consumer, error)

func (*Consumer) Open

func (c *Consumer) Open() error

type ConsumerOption

type ConsumerOption func(*Consumer)

func WithDelayOnErrConsumerOption

func WithDelayOnErrConsumerOption(d DelayOnErr) ConsumerOption

func WithEndpointConsumerOption

func WithEndpointConsumerOption(end endpoint.Endpoint) ConsumerOption

func WithReconnectOnErrConsumerOption

func WithReconnectOnErrConsumerOption(r ReconnectOnErr) ConsumerOption

func WithZkDriver

func WithZkDriver(d driver.Driver) ConsumerOption

type Decoder

type Decoder func(context.Context, interface{}) (interface{}, error)

type DelayOnErr

type DelayOnErr func(error) time.Duration

type ErrorHandler

type ErrorHandler interface{ transport.ErrorHandler }

ErrorHandler is wrapper on top of kit.transport.ErrorHandler

type ReconnectOnErr

type ReconnectOnErr func(error) bool