client

Documentation

Index

• Variables
• type AeronCluster
  • func NewAeronCluster(aeronCtx *aeron.Context, options *Options, egressListener EgressListener) (*AeronCluster, error)
  • func (ac *AeronCluster) Close()
  • func (ac *AeronCluster) ClusterSessionId() int64
  • func (ac *AeronCluster) IsClosed() bool
  • func (ac *AeronCluster) IsConnected() bool
  • func (ac *AeronCluster) LeaderMemberId() int32
  • func (ac *AeronCluster) LeadershipTermId() int64
  • func (ac *AeronCluster) Offer(buffer *atomic.Buffer, offset, length int32) int64
  • func (ac *AeronCluster) Poll() int
  • func (ac *AeronCluster) SendKeepAlive() bool
• type EgressListener
• type Options
  • func NewOptions() *Options

Variables

var TemporaryError = errors.New("temporary error")

Types

type AeronCluster

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

func NewAeronCluster

func NewAeronCluster(
	aeronCtx *aeron.Context,
	options *Options,
	egressListener EgressListener,
) (*AeronCluster, error)

func (*AeronCluster) Close

func (ac *AeronCluster) Close()

func (*AeronCluster) ClusterSessionId

func (ac *AeronCluster) ClusterSessionId() int64

func (*AeronCluster) IsClosed

func (ac *AeronCluster) IsClosed() bool

func (*AeronCluster) IsConnected

func (ac *AeronCluster) IsConnected() bool

func (*AeronCluster) LeaderMemberId

func (ac *AeronCluster) LeaderMemberId() int32

func (*AeronCluster) LeadershipTermId

func (ac *AeronCluster) LeadershipTermId() int64

func (*AeronCluster) Offer

func (ac *AeronCluster) Offer(buffer *atomic.Buffer, offset, length int32) int64

func (*AeronCluster) Poll

func (ac *AeronCluster) Poll() int

func (*AeronCluster) SendKeepAlive

func (ac *AeronCluster) SendKeepAlive() bool

type EgressListener

type EgressListener interface {
	OnConnect(cluster *AeronCluster)

	OnDisconnect(cluster *AeronCluster, details string)

	OnMessage(
		cluster *AeronCluster,
		timestamp int64,
		buffer *atomic.Buffer,
		offset int32,
		length int32,
		header *logbuffer.Header,
	)

	OnNewLeader(
		cluster *AeronCluster,
		leadershipTermId int64,
		leaderMemberId int32,
	)

	OnError(cluster *AeronCluster, details string)
}

type Options

type Options struct {
	RangeChecking      bool
	Loglevel           zapcore.Level // [runtime] via logging.SetLevel()
	IngressEndpoints   string
	IngressChannel     string
	IngressStreamId    int32
	EgressChannel      string
	EgressStreamId     int32
	IdleStrategy       idlestrategy.Idler
	IsIngressExclusive bool
}

func NewOptions

func NewOptions() *Options