cluster

type ClientSession interface {
	Id() int64
	ResponseStreamId() int32
	ResponseChannel() string
	EncodedPrincipal() []byte
	Close()
	// TODO: the other close methods are not part of interface.
	// I don't understand the closing bool implementation and why it is needed
	// Leaving out for now unless it is really important
	// IsClosing() bool
	Offer(*atomic.Buffer, int32, int32, term.ReservedValueSupplier) int64
}

type Cluster interface {
	LogPosition() int64
	MemberId() int32
	Role() Role
	Time() int64
	IdleStrategy() idlestrategy.Idler

	// ScheduleTimer schedules a timer for a given deadline
	ScheduleTimer(correlationId int64, deadline int64) bool
	CancelTimer(correlationId int64) bool
}

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

type ClusteredService interface {
	OnStart(cluster Cluster, image *aeron.Image)

	OnSessionOpen(session ClientSession, timestamp int64)

	OnSessionClose(
		session ClientSession,
		timestamp int64,
		closeReason codecs.CloseReasonEnum,
	)

	OnSessionMessage(
		session ClientSession,
		timestamp int64,
		buffer *atomic.Buffer,
		offset int32,
		length int32,
		header *logbuffer.Header,
	)

	OnTimerEvent(correlationId, timestamp int64)

	OnTakeSnapshot(publication *aeron.Publication)

	OnRoleChange(role Role)

	OnTerminate(cluster Cluster)

	OnNewLeadershipTermEvent(
		leadershipTermId int64,
		logPosition int64,
		timestamp int64,
		termBaseLogPosition int64,
		leaderMemberId int32,
		logSessionId int32,
		timeUnit codecs.ClusterTimeUnitEnum,
		appVersion int32,
	)
}

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

type MarkFileHeaderFlyweight struct {
	flyweight.FWBase

	Version           flyweight.Int32Field
	ComponentType     flyweight.Int32Field
	ActivityTimestamp flyweight.Int64Field
	StartTimestamp    flyweight.Int64Field

	Pid                     flyweight.Int64Field
	CandidateTermId         flyweight.Int64Field
	ArchiveStreamId         flyweight.Int32Field
	ServiceStreamId         flyweight.Int32Field
	ConsensusModuleStreamId flyweight.Int32Field
	IngressStreamId         flyweight.Int32Field
	MemberId                flyweight.Int32Field
	ServiceId               flyweight.Int32Field

	HeaderLength      flyweight.Int32Field
	ErrorBufferLength flyweight.Int32Field
	ClusterId         flyweight.Int32Field
}

type Options struct {
	Timeout                 time.Duration      // [runtime] How long to try sending/receiving control messages
	IdleStrategy            idlestrategy.Idler // [runtime] Idlestrategy for sending/receiving control messagesA
	RangeChecking           bool               // [runtime] archive protocol marshalling checks
	Loglevel                zapcore.Level      // [runtime] via logging.SetLevel()
	ClusterDir              string
	ClusterId               int32
	ServiceId               int32
	AppVersion              int32
	ControlChannel          string
	ConsensusModuleStreamId int32
	ServiceStreamId         int32
	SnapshotChannel         string
	SnapshotStreamId        int32
	ReplayChannel           string
	ReplayStreamId          int32
	ArchiveOptions          *archive.Options
	LogFragmentLimit        int
}

type Role int32