lease

type Agent struct {
	LocalInstance int64
	// contains filtered or unexported fields
}

type AgentConfig struct {
	TLS                      *tls.Config
	AppId                    string
	LeaseDuration            time.Duration
	ApplicationLeaseDuration time.Duration
	LeaseSuspendTimeout      time.Duration
	ArbitrationTimeout       time.Duration
}

type Dialer func(addr string) (net.Conn, error)

type LeaseAgentState int32

type LeaseMessageType int32

type Message struct {
	Identifier               int64
	Type                     LeaseMessageType
	LeaseInstance            int64
	RemoteLeaseAgentInstance int64
	Duration                 time.Duration
	Expiration               time.Duration
	LeaseSuspendDuration     time.Duration
	ArbitrationDuration      time.Duration
	IsTwoWayTermination      bool
	MessageListenEndpoint    string
	// contains filtered or unexported fields
}

type Session interface {
	Meta() SessionMetadata
	// State() LeaseAgentState
	Ping(ctx context.Context) error

	LastPongTime() time.Time

	Close() error
}

type SessionMetadata struct {
	LocalInstance  int64
	RemoteInstance int64
	RemoteEndpoint string
}