server

Documentation

Index

• type Sender
• type ServerConnection
• type ServerConnectionPublisher
• type ServerConnectionSubscriber

Types

type Sender

type Sender interface {
	Send(msg []byte)
}

type ServerConnection

type ServerConnection struct {
	Id               *ServerConnection
	Host             string
	RMId             common.RMId
	BootCount        uint32
	TopologyVerClock *types.VerClock
	ClusterUUId      uint64
	Sender
	Flushed      func()
	ShutdownSync func()
	Status       func(*status.StatusConsumer)
}

type ServerConnectionPublisher

type ServerConnectionPublisher interface {
	AddServerConnectionSubscriber(obs ServerConnectionSubscriber)
	RemoveServerConnectionSubscriber(obs ServerConnectionSubscriber)
}

type ServerConnectionSubscriber

type ServerConnectionSubscriber interface {
	ConnectedRMs(map[common.RMId]ServerConnection)
	ConnectionLost(common.RMId, map[common.RMId]ServerConnection)
	ConnectionEstablished(ServerConnection, map[common.RMId]ServerConnection, func())
}