federation

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 11, 2022

Changes in this version

+ var Federation_ServiceDesc = grpc.ServiceDesc

+ var Membership_ServiceDesc = grpc.ServiceDesc

type Ack

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 Event

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Event) XXX_OneofWrappers() []interface{}

+ 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 ForceLeaveRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 Message

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 ServerHello

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 Subscribe

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 Unsubscribe

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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

v0.4.1

Jul 21, 2021

v0.4.0

Jul 2, 2021

v0.3.2

May 16, 2021

v0.3.1

Apr 18, 2021

v0.3.0

Feb 16, 2021

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL