client

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

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 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
}