Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 Changes in this version + const DefaultFedPort + const DefaultGossipPort + const DefaultRetryInterval + const DefaultRetryTimeout + const Name + var DefaultConfig = Config + var File_federation_proto protoreflect.FileDescriptor + var Status_name = map[int32]string + var Status_value = map[string]int32 + func New(config config.Config) (server.Plugin, error) + func RegisterFederationServer(s grpc.ServiceRegistrar, srv FederationServer) + func RegisterMembershipHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterMembershipHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MembershipClient) error + func RegisterMembershipHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterMembershipHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MembershipServer) error + func RegisterMembershipServer(s grpc.ServiceRegistrar, srv MembershipServer) + type Ack struct + EventId uint64 + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (x *Ack) GetEventId() uint64 + func (x *Ack) ProtoReflect() protoreflect.Message + func (x *Ack) Reset() + func (x *Ack) String() string + type ClientHello struct + SessionId string + func (*ClientHello) Descriptor() ([]byte, []int) + func (*ClientHello) ProtoMessage() + func (x *ClientHello) GetSessionId() string + func (x *ClientHello) ProtoReflect() protoreflect.Message + func (x *ClientHello) Reset() + func (x *ClientHello) String() string + type Config struct + AdvertiseFedAddr string + AdvertiseGossipAddr string + FedAddr string + GossipAddr string + NodeName string + RejoinAfterLeave bool + RetryInterval time.Duration + RetryJoin []string + RetryTimeout time.Duration + SnapshotPath string + func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error + func (c *Config) Validate() (err error) + type Event struct + Event isEvent_Event + Id uint64 + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetEvent() isEvent_Event + func (x *Event) GetId() uint64 + func (x *Event) GetMessage() *Message + func (x *Event) GetSubscribe() *Subscribe + func (x *Event) GetUnsubscribe() *Unsubscribe + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type Event_Message struct + Message *Message + type Event_Subscribe struct + Subscribe *Subscribe + type Event_Unsubscribe struct + Unsubscribe *Unsubscribe + type Federation struct + func (f *Federation) EventStream(stream Federation_EventStreamServer) (err error) + func (f *Federation) ForceLeave(ctx context.Context, req *ForceLeaveRequest) (*empty.Empty, error) + func (f *Federation) Hello(ctx context.Context, req *ClientHello) (resp *ServerHello, err error) + func (f *Federation) HookWrapper() server.HookWrapper + func (f *Federation) Join(ctx context.Context, req *JoinRequest) (resp *empty.Empty, err error) + func (f *Federation) Leave(ctx context.Context, req *empty.Empty) (resp *empty.Empty, err error) + func (f *Federation) ListMembers(ctx context.Context, req *empty.Empty) (resp *ListMembersResponse, err error) + func (f *Federation) Load(service server.Server) error + func (f *Federation) Name() string + func (f *Federation) OnMsgArrivedWrapper(pre server.OnMsgArrived) server.OnMsgArrived + func (f *Federation) OnSessionTerminatedWrapper(pre server.OnSessionTerminated) server.OnSessionTerminated + func (f *Federation) OnSubscribedWrapper(pre server.OnSubscribed) server.OnSubscribed + func (f *Federation) OnUnsubscribedWrapper(pre server.OnUnsubscribed) server.OnUnsubscribed + func (f *Federation) OnWillPublishWrapper(pre server.OnWillPublish) server.OnWillPublish + func (f *Federation) Unload() error + type FederationClient interface + EventStream func(ctx context.Context, opts ...grpc.CallOption) (Federation_EventStreamClient, error) + Hello func(ctx context.Context, in *ClientHello, opts ...grpc.CallOption) (*ServerHello, error) + func NewFederationClient(cc grpc.ClientConnInterface) FederationClient + type FederationServer interface + EventStream func(Federation_EventStreamServer) error + Hello func(context.Context, *ClientHello) (*ServerHello, error) + type Federation_EventStreamClient interface + Recv func() (*Ack, error) + Send func(*Event) error + type Federation_EventStreamServer interface + Recv func() (*Event, error) + Send func(*Ack) error + type ForceLeaveRequest struct + NodeName string + func (*ForceLeaveRequest) Descriptor() ([]byte, []int) + func (*ForceLeaveRequest) ProtoMessage() + func (x *ForceLeaveRequest) GetNodeName() string + func (x *ForceLeaveRequest) ProtoReflect() protoreflect.Message + func (x *ForceLeaveRequest) Reset() + func (x *ForceLeaveRequest) String() string + type JoinRequest struct + Hosts []string + func (*JoinRequest) Descriptor() ([]byte, []int) + func (*JoinRequest) ProtoMessage() + func (x *JoinRequest) GetHosts() []string + func (x *JoinRequest) ProtoReflect() protoreflect.Message + func (x *JoinRequest) Reset() + func (x *JoinRequest) String() string + type ListMembersResponse struct + Members []*Member + func (*ListMembersResponse) Descriptor() ([]byte, []int) + func (*ListMembersResponse) ProtoMessage() + func (x *ListMembersResponse) GetMembers() []*Member + func (x *ListMembersResponse) ProtoReflect() protoreflect.Message + func (x *ListMembersResponse) Reset() + func (x *ListMembersResponse) String() string + type Member struct + Addr string + Name string + Status Status + Tags map[string]string + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (x *Member) GetAddr() string + func (x *Member) GetName() string + func (x *Member) GetStatus() Status + func (x *Member) GetTags() map[string]string + func (x *Member) ProtoReflect() protoreflect.Message + func (x *Member) Reset() + func (x *Member) String() string + type MembershipClient interface + ForceLeave func(ctx context.Context, in *ForceLeaveRequest, opts ...grpc.CallOption) (*empty.Empty, error) + Join func(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*empty.Empty, error) + Leave func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) + ListMembers func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListMembersResponse, error) + func NewMembershipClient(cc grpc.ClientConnInterface) MembershipClient + type MembershipServer interface + ForceLeave func(context.Context, *ForceLeaveRequest) (*empty.Empty, error) + Join func(context.Context, *JoinRequest) (*empty.Empty, error) + Leave func(context.Context, *empty.Empty) (*empty.Empty, error) + ListMembers func(context.Context, *empty.Empty) (*ListMembersResponse, error) + type Message struct + ContentType string + CorrelationData string + MessageExpiry uint32 + Payload string + PayloadFormat uint32 + Qos uint32 + ResponseTopic string + Retained bool + TopicName string + UserProperties []*UserProperty + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetContentType() string + func (x *Message) GetCorrelationData() string + func (x *Message) GetMessageExpiry() uint32 + func (x *Message) GetPayload() string + func (x *Message) GetPayloadFormat() uint32 + func (x *Message) GetQos() uint32 + func (x *Message) GetResponseTopic() string + func (x *Message) GetRetained() bool + func (x *Message) GetTopicName() string + func (x *Message) GetUserProperties() []*UserProperty + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type MockFederationClient struct + func NewMockFederationClient(ctrl *gomock.Controller) *MockFederationClient + func (m *MockFederationClient) EXPECT() *MockFederationClientMockRecorder + func (m *MockFederationClient) EventStream(arg0 context.Context, arg1 ...grpc.CallOption) (Federation_EventStreamClient, error) + func (m *MockFederationClient) Hello(arg0 context.Context, arg1 *ClientHello, arg2 ...grpc.CallOption) (*ServerHello, error) + type MockFederationClientMockRecorder struct + func (mr *MockFederationClientMockRecorder) EventStream(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockFederationClientMockRecorder) Hello(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + type MockFederation_EventStreamClient struct + func NewMockFederation_EventStreamClient(ctrl *gomock.Controller) *MockFederation_EventStreamClient + func (m *MockFederation_EventStreamClient) CloseSend() error + func (m *MockFederation_EventStreamClient) Context() context.Context + func (m *MockFederation_EventStreamClient) EXPECT() *MockFederation_EventStreamClientMockRecorder + func (m *MockFederation_EventStreamClient) Header() (metadata.MD, error) + func (m *MockFederation_EventStreamClient) Recv() (*Ack, error) + func (m *MockFederation_EventStreamClient) RecvMsg(arg0 interface{}) error + func (m *MockFederation_EventStreamClient) Send(arg0 *Event) error + func (m *MockFederation_EventStreamClient) SendMsg(arg0 interface{}) error + func (m *MockFederation_EventStreamClient) Trailer() metadata.MD + type MockFederation_EventStreamClientMockRecorder struct + func (mr *MockFederation_EventStreamClientMockRecorder) CloseSend() *gomock.Call + func (mr *MockFederation_EventStreamClientMockRecorder) Context() *gomock.Call + func (mr *MockFederation_EventStreamClientMockRecorder) Header() *gomock.Call + func (mr *MockFederation_EventStreamClientMockRecorder) Recv() *gomock.Call + func (mr *MockFederation_EventStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call + func (mr *MockFederation_EventStreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockFederation_EventStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call + func (mr *MockFederation_EventStreamClientMockRecorder) Trailer() *gomock.Call + type MockiSerf struct + func NewMockiSerf(ctrl *gomock.Controller) *MockiSerf + func (m *MockiSerf) EXPECT() *MockiSerfMockRecorder + func (m *MockiSerf) Join(existing []string, ignoreOld bool) (int, error) + func (m *MockiSerf) Leave() error + func (m *MockiSerf) Members() []serf.Member + func (m *MockiSerf) RemoveFailedNode(node string) error + func (m *MockiSerf) Shutdown() error + type MockiSerfMockRecorder struct + func (mr *MockiSerfMockRecorder) Join(existing, ignoreOld interface{}) *gomock.Call + func (mr *MockiSerfMockRecorder) Leave() *gomock.Call + func (mr *MockiSerfMockRecorder) Members() *gomock.Call + func (mr *MockiSerfMockRecorder) RemoveFailedNode(node interface{}) *gomock.Call + func (mr *MockiSerfMockRecorder) Shutdown() *gomock.Call + type MockisEvent_Event struct + func NewMockisEvent_Event(ctrl *gomock.Controller) *MockisEvent_Event + func (m *MockisEvent_Event) EXPECT() *MockisEvent_EventMockRecorder + type MockisEvent_EventMockRecorder struct + type Mockqueue struct + func NewMockqueue(ctrl *gomock.Controller) *Mockqueue + func (m *Mockqueue) EXPECT() *MockqueueMockRecorder + type MockqueueMockRecorder struct + type ServerHello struct + CleanStart bool + NextEventId uint64 + func (*ServerHello) Descriptor() ([]byte, []int) + func (*ServerHello) ProtoMessage() + func (x *ServerHello) GetCleanStart() bool + func (x *ServerHello) GetNextEventId() uint64 + func (x *ServerHello) ProtoReflect() protoreflect.Message + func (x *ServerHello) Reset() + func (x *ServerHello) String() string + type Status int32 + const Status_STATUS_ALIVE + const Status_STATUS_FAILED + const Status_STATUS_LEAVING + const Status_STATUS_LEFT + const Status_STATUS_UNSPECIFIED + func (Status) Descriptor() protoreflect.EnumDescriptor + func (Status) EnumDescriptor() ([]byte, []int) + func (Status) Type() protoreflect.EnumType + func (x Status) Enum() *Status + func (x Status) Number() protoreflect.EnumNumber + func (x Status) String() string + type Subscribe struct + ShareName string + TopicFilter string + func (*Subscribe) Descriptor() ([]byte, []int) + func (*Subscribe) ProtoMessage() + func (x *Subscribe) GetShareName() string + func (x *Subscribe) GetTopicFilter() string + func (x *Subscribe) ProtoReflect() protoreflect.Message + func (x *Subscribe) Reset() + func (x *Subscribe) String() string + type UnimplementedFederationServer struct + func (UnimplementedFederationServer) EventStream(Federation_EventStreamServer) error + func (UnimplementedFederationServer) Hello(context.Context, *ClientHello) (*ServerHello, error) + type UnimplementedMembershipServer struct + func (UnimplementedMembershipServer) ForceLeave(context.Context, *ForceLeaveRequest) (*empty.Empty, error) + func (UnimplementedMembershipServer) Join(context.Context, *JoinRequest) (*empty.Empty, error) + func (UnimplementedMembershipServer) Leave(context.Context, *empty.Empty) (*empty.Empty, error) + func (UnimplementedMembershipServer) ListMembers(context.Context, *empty.Empty) (*ListMembersResponse, error) + type UnsafeFederationServer interface + type UnsafeMembershipServer interface + type Unsubscribe struct + TopicName string + func (*Unsubscribe) Descriptor() ([]byte, []int) + func (*Unsubscribe) ProtoMessage() + func (x *Unsubscribe) GetTopicName() string + func (x *Unsubscribe) ProtoReflect() protoreflect.Message + func (x *Unsubscribe) Reset() + func (x *Unsubscribe) String() string + type UserProperty struct + K []byte + V []byte + func (*UserProperty) Descriptor() ([]byte, []int) + func (*UserProperty) ProtoMessage() + func (x *UserProperty) GetK() []byte + func (x *UserProperty) GetV() []byte + func (x *UserProperty) ProtoReflect() protoreflect.Message + func (x *UserProperty) Reset() + func (x *UserProperty) String() string