ha

Documentation

Index

• Constants
• type ConfirmMessageHandler
• type ReliableProducer
  • func NewHAProducer(env *stream.Environment, streamName string, ...) (*ReliableProducer, error)
  • func (p *ReliableProducer) BatchSend(messages []message.StreamMessage) error
  • func (p *ReliableProducer) Close() error
  • func (p *ReliableProducer) GetBroker() *stream.Broker
  • func (p *ReliableProducer) IsOpen() bool
  • func (p *ReliableProducer) Send(message message.StreamMessage) error

Constants

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

Types

type ConfirmMessageHandler

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

type ReliableProducer

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

func NewHAProducer

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

func (*ReliableProducer) BatchSend

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

func (*ReliableProducer) Close

func (p *ReliableProducer) Close() error

func (*ReliableProducer) GetBroker

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

func (*ReliableProducer) IsOpen

func (p *ReliableProducer) IsOpen() bool

func (*ReliableProducer) Send

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