consumer

type Configuration struct {
	Encoder                   *proto.Configuration          `yaml:"encoder"`
	Decoder                   *proto.Configuration          `yaml:"decoder"`
	MessagePool               *pool.ObjectPoolConfiguration `yaml:"messagePool"`
	AckFlushInterval          *time.Duration                `yaml:"ackFlushInterval"`
	AckBufferSize             *int                          `yaml:"ackBufferSize"`
	ConnectionWriteBufferSize *int                          `yaml:"connectionWriteBufferSize"`
	ConnectionReadBufferSize  *int                          `yaml:"connectionReadBufferSize"`
}

type ConsumeFn func(c Consumer)

type Consumer interface {
	// Message waits for and returns the next message received.
	Message() (Message, error)

	// Init initializes the consumer.
	Init()

	// Close closes the consumer.
	Close()
}

type Listener interface {
	// Accept waits for and returns the next connection based consumer.
	Accept() (Consumer, error)

	// Close closes the listener.
	// Any blocked Accept operations will be unblocked and return errors.
	Close() error

	// Addr returns the listener's network address.
	Addr() net.Addr
}

type Message interface {
	// Bytes returns the bytes.
	Bytes() []byte

	// Ack acks the message.
	Ack()
}

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

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

type Options interface {
	// EncoderOptions returns the options for Encoder.
	EncoderOptions() proto.Options

	// SetEncoderOptions sets the options for Encoder.
	SetEncoderOptions(value proto.Options) Options

	// DecoderOptions returns the options for Decoder.
	DecoderOptions() proto.Options

	// SetDecoderOptions sets the options for Decoder.
	SetDecoderOptions(value proto.Options) Options

	// MessagePoolOptions returns the options for message pool.
	MessagePoolOptions() pool.ObjectPoolOptions

	// SetMessagePoolOptions sets the options for message pool.
	SetMessagePoolOptions(value pool.ObjectPoolOptions) Options

	// AckFlushInterval returns the ack flush interval.
	AckFlushInterval() time.Duration

	// SetAckFlushInterval sets the ack flush interval.
	SetAckFlushInterval(value time.Duration) Options

	// AckBufferSize returns the ack buffer size.
	AckBufferSize() int

	// SetAckBufferSize sets the ack buffer size.
	SetAckBufferSize(value int) Options

	// ConnectionWriteBufferSize returns the size of buffer before a write or a read.
	ConnectionWriteBufferSize() int

	// SetConnectionWriteBufferSize sets the buffer size.
	SetConnectionWriteBufferSize(value int) Options

	// ConnectionReadBufferSize returns the size of buffer before a write or a read.
	ConnectionReadBufferSize() int

	// SetConnectionWriteBufferSize sets the buffer size.
	SetConnectionReadBufferSize(value int) Options

	// InstrumentOptions returns the instrument options.
	InstrumentOptions() instrument.Options

	// SetInstrumentOptions sets the instrument options.
	SetInstrumentOptions(value instrument.Options) Options
}

type ServerOptions interface {
	// ConsumeFn returns the ConsumeFn.
	ConsumeFn() ConsumeFn

	// SetConsumeFn sets the ConsumeFn.
	SetConsumeFn(value ConsumeFn) ServerOptions

	// RetryOptions returns the options for connection retrier.
	ServerOptions() server.Options

	// SetRetryOptions sets the options for connection retrier.
	SetServerOptions(value server.Options) ServerOptions

	// InstrumentOptions returns the instrument options.
	ConsumerOptions() Options

	// SetInstrumentOptions sets the instrument options.
	SetConsumerOptions(value Options) ServerOptions
}