remoting

Aug 16, 2022

Changes in this version

+ var ErrConnectionClosed = errors.New("connection closed")

+ var ErrInsufficientServers = errors.New("insufficient servers available")

+ type BroadcastWrapper struct

+ func NewBroadcastWrapper(serverAddresses ...string) *BroadcastWrapper

+ func (b *BroadcastWrapper) Broadcast(request ClusterMessage) error

+ func (b *BroadcastWrapper) Stop()

+ type Broadcaster interface

+ Broadcast func(request ClusterMessage) error

+ Stop func()

type Client

+ func (c *Client) Broadcast(request ClusterMessage, minServers int, serverAddresses ...string) error

+ func (c *Client) BroadcastOneWay(request ClusterMessage, serverAddresses ...string)

+ func (c *Client) SendRPC(request ClusterMessage, serverAddress string) (ClusterMessage, error)

type ClusterMessageType

+ const ClusterMessageDDLCancel

+ const ClusterMessageForwardWriteRequest

+ const ClusterMessageForwardWriteResponse

+ const ClusterMessageLeaderInfos

+ const ClusterMessageRemotingTestMessage

+ const ClusterMessageSourceSetMaxRate

+ type FakeClient struct

+ func NewFakeClient(fakeServer *FakeServer) *FakeClient

+ func (f *FakeClient) Broadcast(clusterMsg ClusterMessage) error

+ func (f *FakeClient) Stop()

type FakeServer

+ func (f *FakeServer) ServerAddresses() []string

+ type RPCSender interface

+ SendRPC func(request ClusterMessage) (ClusterMessage, error)

+ Stop func()

+ type RPCWrapper struct

+ func NewRPCWrapper(serverAddress string) *RPCWrapper

+ func (r *RPCWrapper) SendRPC(request ClusterMessage) (ClusterMessage, error)

+ func (r *RPCWrapper) Stop()

Jun 23, 2022

Changes in this version

+ type AvailabilityListener interface

+ AvailabilityChanged func(serverAddresses []string)

+ type Client interface

+ AvailabilityListener func() AvailabilityListener

+ BroadcastOneway func(notif ClusterMessage) error

+ BroadcastSync func(notif ClusterMessage) error

+ SendRequest func(message ClusterMessage, timeout time.Duration) (ClusterMessage, error)

+ Start func() error

+ Stop func() error

+ func NewClient(serverAddresses ...string) Client

+ type ClusterMessage = proto.Message

+ func DeserializeClusterMessage(data []byte) (ClusterMessage, error)

+ type ClusterMessageHandler interface

+ HandleMessage func(notification ClusterMessage) (ClusterMessage, error)

+ type ClusterMessageType int32

+ const ClusterMessageClusterProposeRequest

+ const ClusterMessageClusterProposeResponse

+ const ClusterMessageClusterReadRequest

+ const ClusterMessageClusterReadResponse

+ const ClusterMessageDDLStatement

+ const ClusterMessageNotificationTestMessage

+ const ClusterMessageReloadProtobuf

+ const ClusterMessageTypeUnknown

+ func TypeForClusterMessage(notification ClusterMessage) ClusterMessageType

+ type ClusterRequest struct

+ type ClusterResponse struct

+ type FakeServer struct

+ func NewFakeServer() *FakeServer

+ func (f *FakeServer) AvailabilityListener() AvailabilityListener

+ func (f *FakeServer) BroadcastOneway(notif ClusterMessage) error

+ func (f *FakeServer) BroadcastSync(notif ClusterMessage) error

+ func (f *FakeServer) ConnectionCount() int

+ func (f *FakeServer) RegisterMessageHandler(notificationType ClusterMessageType, listener ClusterMessageHandler)

+ func (f *FakeServer) SendRequest(notif ClusterMessage, timeout time.Duration) (ClusterMessage, error)

+ func (f *FakeServer) Start() error

+ func (f *FakeServer) Stop() error

+ type HealthChecker struct

+ func NewHealthChecker(serverAddresses []string, hbTimeout time.Duration, hbInterval time.Duration) *HealthChecker

+ func (h *HealthChecker) AddAvailabilityListener(listener AvailabilityListener)

+ func (h *HealthChecker) Start()

+ func (h *HealthChecker) Stop()

+ type Server interface

+ RegisterMessageHandler func(messageType ClusterMessageType, listener ClusterMessageHandler)

+ Start func() error

+ Stop func() error

+ func NewServer(listenAddress string) Server