ha

Documentation

Index

• Constants
• type ConfirmMessageHandler
• type IReliable
• type ReliableConsumer
  • func NewReliableConsumer(env *stream.Environment, streamName string, ...) (*ReliableConsumer, error)
  • func (c *ReliableConsumer) Close() error
  • func (c *ReliableConsumer) GetStatus() int
• type ReliableProducer
  • func NewReliableProducer(env *stream.Environment, streamName string, ...) (*ReliableProducer, error)
  • func (p *ReliableProducer) Close() error
  • func (p *ReliableProducer) GetBroker() *stream.Broker
  • func (p *ReliableProducer) GetStatus() int
  • func (p *ReliableProducer) IsOpen() bool
  • func (p *ReliableProducer) Send(message message.StreamMessage) error

Constants

const (
	StatusOpen               = 1
	StatusClosed             = 2
	StatusStreamDoesNotExist = 3
	StatusReconnecting       = 4
)

Types

type ConfirmMessageHandler

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

type IReliable

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

type ReliableConsumer

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

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

func (*ReliableConsumer) Close

func (c *ReliableConsumer) Close() error

func (*ReliableConsumer) GetStatus

func (c *ReliableConsumer) GetStatus() int

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 function `send` is blocked during the reconnection

func NewReliableProducer

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

func (*ReliableProducer) Close

func (p *ReliableProducer) Close() error

func (*ReliableProducer) GetBroker

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

func (*ReliableProducer) GetStatus

func (p *ReliableProducer) GetStatus() int

func (*ReliableProducer) IsOpen

func (p *ReliableProducer) IsOpen() bool

func (*ReliableProducer) Send

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