Versions in this module Expand all Collapse all v0 v0.5.2 Jan 31, 2023 Changes in this version + const DefaultFedPort + const DefaultGossipPort + const DefaultRetryInterval + const DefaultRetryTimeout + const Name + var DefaultConfig = Config + var Federation_ServiceDesc = grpc.ServiceDesc + var Membership_ServiceDesc = grpc.ServiceDesc + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (m *Ack) GetEventId() uint64 + func (m *Ack) Reset() + func (m *Ack) String() string + func (m *Ack) XXX_DiscardUnknown() + func (m *Ack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ack) XXX_Merge(src proto.Message) + func (m *Ack) XXX_Size() int + func (m *Ack) XXX_Unmarshal(b []byte) error + type ClientHello struct + SessionId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientHello) Descriptor() ([]byte, []int) + func (*ClientHello) ProtoMessage() + func (m *ClientHello) GetSessionId() string + func (m *ClientHello) Reset() + func (m *ClientHello) String() string + func (m *ClientHello) XXX_DiscardUnknown() + func (m *ClientHello) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientHello) XXX_Merge(src proto.Message) + func (m *ClientHello) XXX_Size() int + func (m *ClientHello) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (*Event) XXX_OneofWrappers() []interface{} + func (m *Event) GetEvent() isEvent_Event + func (m *Event) GetId() uint64 + func (m *Event) GetMessage() *Message + func (m *Event) GetSubscribe() *Subscribe + func (m *Event) GetUnsubscribe() *Unsubscribe + func (m *Event) Reset() + func (m *Event) String() string + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ForceLeaveRequest) Descriptor() ([]byte, []int) + func (*ForceLeaveRequest) ProtoMessage() + func (m *ForceLeaveRequest) GetNodeName() string + func (m *ForceLeaveRequest) Reset() + func (m *ForceLeaveRequest) String() string + func (m *ForceLeaveRequest) XXX_DiscardUnknown() + func (m *ForceLeaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ForceLeaveRequest) XXX_Merge(src proto.Message) + func (m *ForceLeaveRequest) XXX_Size() int + func (m *ForceLeaveRequest) XXX_Unmarshal(b []byte) error + type JoinRequest struct + Hosts []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*JoinRequest) Descriptor() ([]byte, []int) + func (*JoinRequest) ProtoMessage() + func (m *JoinRequest) GetHosts() []string + func (m *JoinRequest) Reset() + func (m *JoinRequest) String() string + func (m *JoinRequest) XXX_DiscardUnknown() + func (m *JoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JoinRequest) XXX_Merge(src proto.Message) + func (m *JoinRequest) XXX_Size() int + func (m *JoinRequest) XXX_Unmarshal(b []byte) error + type ListMembersResponse struct + Members []*Member + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListMembersResponse) Descriptor() ([]byte, []int) + func (*ListMembersResponse) ProtoMessage() + func (m *ListMembersResponse) GetMembers() []*Member + func (m *ListMembersResponse) Reset() + func (m *ListMembersResponse) String() string + func (m *ListMembersResponse) XXX_DiscardUnknown() + func (m *ListMembersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListMembersResponse) XXX_Merge(src proto.Message) + func (m *ListMembersResponse) XXX_Size() int + func (m *ListMembersResponse) XXX_Unmarshal(b []byte) error + type Member struct + Addr string + Name string + Status Status + Tags map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (m *Member) GetAddr() string + func (m *Member) GetName() string + func (m *Member) GetStatus() Status + func (m *Member) GetTags() map[string]string + func (m *Member) Reset() + func (m *Member) String() string + func (m *Member) XXX_DiscardUnknown() + func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Member) XXX_Merge(src proto.Message) + func (m *Member) XXX_Size() int + func (m *Member) XXX_Unmarshal(b []byte) error + 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 []byte + PayloadFormat uint32 + Qos uint32 + ResponseTopic string + Retained bool + TopicName string + UserProperties []*UserProperty + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetContentType() string + func (m *Message) GetCorrelationData() string + func (m *Message) GetMessageExpiry() uint32 + func (m *Message) GetPayload() []byte + func (m *Message) GetPayloadFormat() uint32 + func (m *Message) GetQos() uint32 + func (m *Message) GetResponseTopic() string + func (m *Message) GetRetained() bool + func (m *Message) GetTopicName() string + func (m *Message) GetUserProperties() []*UserProperty + func (m *Message) Reset() + func (m *Message) String() string + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Merge(src proto.Message) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServerHello) Descriptor() ([]byte, []int) + func (*ServerHello) ProtoMessage() + func (m *ServerHello) GetCleanStart() bool + func (m *ServerHello) GetNextEventId() uint64 + func (m *ServerHello) Reset() + func (m *ServerHello) String() string + func (m *ServerHello) XXX_DiscardUnknown() + func (m *ServerHello) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerHello) XXX_Merge(src proto.Message) + func (m *ServerHello) XXX_Size() int + func (m *ServerHello) XXX_Unmarshal(b []byte) error + 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) EnumDescriptor() ([]byte, []int) + func (x Status) String() string + type Subscribe struct + ShareName string + TopicFilter string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Subscribe) Descriptor() ([]byte, []int) + func (*Subscribe) ProtoMessage() + func (m *Subscribe) GetShareName() string + func (m *Subscribe) GetTopicFilter() string + func (m *Subscribe) Reset() + func (m *Subscribe) String() string + func (m *Subscribe) XXX_DiscardUnknown() + func (m *Subscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Subscribe) XXX_Merge(src proto.Message) + func (m *Subscribe) XXX_Size() int + func (m *Subscribe) XXX_Unmarshal(b []byte) error + 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Unsubscribe) Descriptor() ([]byte, []int) + func (*Unsubscribe) ProtoMessage() + func (m *Unsubscribe) GetTopicName() string + func (m *Unsubscribe) Reset() + func (m *Unsubscribe) String() string + func (m *Unsubscribe) XXX_DiscardUnknown() + func (m *Unsubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Unsubscribe) XXX_Merge(src proto.Message) + func (m *Unsubscribe) XXX_Size() int + func (m *Unsubscribe) XXX_Unmarshal(b []byte) error + type UserProperty struct + K []byte + V []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UserProperty) Descriptor() ([]byte, []int) + func (*UserProperty) ProtoMessage() + func (m *UserProperty) GetK() []byte + func (m *UserProperty) GetV() []byte + func (m *UserProperty) Reset() + func (m *UserProperty) String() string + func (m *UserProperty) XXX_DiscardUnknown() + func (m *UserProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UserProperty) XXX_Merge(src proto.Message) + func (m *UserProperty) XXX_Size() int + func (m *UserProperty) XXX_Unmarshal(b []byte) error
Go to main page