ha

type ConfirmMessageHandler ¶

type ConfirmMessageHandler func(messageConfirm []*stream.ConfirmationStatus)

type IReliable ¶ added in v1.3.1

type IReliable interface {
	GetStatus() int
	GetStreamName() string
	GetStatusAsString() string
	// contains filtered or unexported methods
}

type PartitionConfirmMessageHandler ¶ added in v1.6.0

type PartitionConfirmMessageHandler func(messageConfirm []*stream.PartitionPublishConfirm)

type ReliableConsumer ¶ added in v1.3.1

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

ReliableConsumer is a consumer that can reconnect in case of connection problems the function messagesHandler is mandatory

func NewReliableConsumer(env *stream.Environment, streamName string,
	consumerOptions *stream.ConsumerOptions, messagesHandler stream.MessagesHandler) (*ReliableConsumer, error)

func (c *ReliableConsumer) Close() error

func (c *ReliableConsumer) GetInfo() string

func (c *ReliableConsumer) GetStatus() int

func (c *ReliableConsumer) GetStatusAsString() string

func (c *ReliableConsumer) GetStreamName() string

type ReliableProducer ¶

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

ReliableProducer is a producer that can reconnect in case of connection problems the function handlePublishConfirm is mandatory in case of problems the messages have the message.Confirmed == false The functions `Send` and `SendBatch` are blocked during the reconnection

func NewReliableProducer(env *stream.Environment, streamName string,
	producerOptions *stream.ProducerOptions,
	confirmMessageHandler ConfirmMessageHandler) (*ReliableProducer, error)

func (p *ReliableProducer) BatchSend(batchMessages []message.StreamMessage) error

func (p *ReliableProducer) Close() error

func (p *ReliableProducer) GetBroker() *stream.Broker

func (p *ReliableProducer) GetInfo() string

func (p *ReliableProducer) GetStatus() int

func (p *ReliableProducer) GetStatusAsString() string

func (p *ReliableProducer) GetStreamName() string

func (p *ReliableProducer) IsOpen() bool

func (p *ReliableProducer) Send(message message.StreamMessage) error

type ReliableSuperStreamConsumer ¶ added in v1.6.0

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

func NewReliableSuperStreamConsumer(env *stream.Environment, superStream string, messagesHandler stream.MessagesHandler, consumerOptions *stream.SuperStreamConsumerOptions) (*ReliableSuperStreamConsumer, error)

func (r *ReliableSuperStreamConsumer) Close() error

func (r *ReliableSuperStreamConsumer) GetStatus() int

func (r *ReliableSuperStreamConsumer) GetStatusAsString() string

func (r *ReliableSuperStreamConsumer) GetStreamName() string

type ReliableSuperStreamProducer ¶ added in v1.6.0

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

func NewReliableSuperStreamProducer(env *stream.Environment, superStream string,
	superStreamProducerOptions *stream.SuperStreamProducerOptions, partitionConfirmMessageHandler PartitionConfirmMessageHandler) (*ReliableSuperStreamProducer, error)

func (r *ReliableSuperStreamProducer) Close() error

func (r *ReliableSuperStreamProducer) GetStatus() int

func (r *ReliableSuperStreamProducer) GetStatusAsString() string

func (r *ReliableSuperStreamProducer) GetStreamName() string

func (r *ReliableSuperStreamProducer) Send(message message.StreamMessage) error