Documentation ¶
Index ¶
- type ByzantineBrokerServer
- func (ByzantineBrokerServer) Chain(context.Context, *byzantine.Publication) (*byzantine.ChainResponse, error)
- func (bz *ByzantineBrokerServer) Echo(ctx context.Context, pub *byzantine.Publication) (*byzantine.EchoResponse, error)
- func (bz *ByzantineBrokerServer) GetSubscribers(sub *byzantine.Subscriber, stream byzantine.Broker_GetSubscribersServer) error
- func (ByzantineBrokerServer) Push(byzantine.Broker_PushServer) error
- func (bz *ByzantineBrokerServer) Ready(context.Context, *byzantine.Publication) (*byzantine.ReadyResponse, error)
- func (ByzantineBrokerServer) Receive(context.Context, *byzantine.Publication) (*byzantine.PubResponse, error)
- func (bz *ByzantineBrokerServer) RegisterSubscriber(ctx context.Context, sub *byzantine.Subscriber) (*byzantine.ReadyResponse, error)
- type ByzantinePublisherServer
- type ByzantineSubscriberServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ByzantineBrokerServer ¶
type ByzantineBrokerServer struct {
// contains filtered or unexported fields
}
func (ByzantineBrokerServer) Chain ¶
func (ByzantineBrokerServer) Chain(context.Context, *byzantine.Publication) (*byzantine.ChainResponse, error)
func (*ByzantineBrokerServer) Echo ¶
func (bz *ByzantineBrokerServer) Echo(ctx context.Context, pub *byzantine.Publication) (*byzantine.EchoResponse, error)
Echo receives a blank message from the publisher as a heartbeat.
func (*ByzantineBrokerServer) GetSubscribers ¶
func (bz *ByzantineBrokerServer) GetSubscribers(sub *byzantine.Subscriber, stream byzantine.Broker_GetSubscribersServer) error
GetSubscribers returns a list of the subscribers. The request must come from a subscribed member.
func (ByzantineBrokerServer) Push ¶
func (ByzantineBrokerServer) Push(byzantine.Broker_PushServer) error
func (*ByzantineBrokerServer) Ready ¶
func (bz *ByzantineBrokerServer) Ready(context.Context, *byzantine.Publication) (*byzantine.ReadyResponse, error)
func (ByzantineBrokerServer) Receive ¶
func (ByzantineBrokerServer) Receive(context.Context, *byzantine.Publication) (*byzantine.PubResponse, error)
func (*ByzantineBrokerServer) RegisterSubscriber ¶
func (bz *ByzantineBrokerServer) RegisterSubscriber(ctx context.Context, sub *byzantine.Subscriber) (*byzantine.ReadyResponse, error)
RegisterSubscriber registers a new subscriber to the broker server.
type ByzantinePublisherServer ¶
type ByzantinePublisherServer struct { *byzantine.Publisher CacheStore *bigcache.BigCache Logger grpclog.Logger }
func NewPublisherServer ¶
func NewPublisherServer() *ByzantinePublisherServer
type ByzantineSubscriberServer ¶
type ByzantineSubscriberServer struct { *byzantine.Subscriber Logger *grpclog.Logger }
Click to show internal directories.
Click to hide internal directories.