Versions in this module Expand all Collapse all v0 v0.4.1 Nov 17, 2020 v0.4.0 Nov 17, 2020 v0.3.1 Oct 22, 2020 Changes in this version type Group + func NewGroupWithContext(ctx context.Context, address string, opts ...Option) (*Group, error) v0.3.0 Oct 12, 2020 v0.2.4 Sep 8, 2020 v0.2.3 Sep 2, 2020 v0.2.2 Aug 27, 2020 v0.2.1 Jun 3, 2020 Changes in this version + type ConnectOption interface + func WithDialOption(option grpc.DialOption) ConnectOption + func WithDialOptions(options ...grpc.DialOption) ConnectOption type Option + func WithHost(host string) Option + func WithPort(port int) Option + func WithServerOption(option grpc.ServerOption) Option + func WithServerOptions(options ...grpc.ServerOption) Option + func WithServices(services ...Service) Option v0.2.0 May 21, 2020 Changes in this version + type Group struct + Name string + Namespace string + func NewGroup(address string, opts ...Option) (*Group, error) + func (c *Group) Close() error + func (c *Group) Member() *Peer + func (c *Group) Peer(id ID) *Peer + func (c *Group) Peers() Set + func (c *Group) Watch(ctx context.Context, ch chan<- Set) error + type ID string + type Member struct + func NewMember(id ID, host string, port int, services ...Service) *Member + func (m *Member) Stop() + type Option interface + func WithApplication(application string) Option + func WithJoinTimeout(timeout time.Duration) Option + func WithMemberID(memberID string) Option + func WithNamespace(namespace string) Option + func WithPeerHost(host string) Option + func WithPeerPort(port int) Option + func WithScope(scope string) Option + func WithService(service Service) Option + type Peer struct + Host string + ID ID + Port int + func NewPeer(id ID, host string, port int) *Peer + func (m *Peer) Connect() (*grpc.ClientConn, error) + type Service func(ID, *grpc.Server) + type Set map[ID]*Peer
Go to main page