example

Documentation

Index

• type ClusteredInviteClient
  • func NewClusteredInviteClient(cc grpc.ClientConnInterface) *ClusteredInviteClient
  • func (c *ClusteredInviteClient) GetInvitationStatus(ctx context.Context, in *invitepb.GetInvitationStatusRequest, ...) (*invitepb.GetInvitationStatusResponse, error)
  • func (c *ClusteredInviteClient) GetInviteCount(ctx context.Context, in *invitepb.GetInviteCountRequest, ...) (*invitepb.GetInviteCountResponse, error)
  • func (c *ClusteredInviteClient) InvitePhoneNumber(ctx context.Context, in *invitepb.InvitePhoneNumberRequest, ...) (*invitepb.InvitePhoneNumberResponse, error)
• type ClusteredInviteService
  • func NewClusteredInviteService(nodeID string, serverID int, registry registry.Observer, ...) *ClusteredInviteService
  • func (c *ClusteredInviteService) Close()
  • func (c *ClusteredInviteService) GetInviteCount(ctx context.Context, req *invitepb.GetInviteCountRequest) (*invitepb.GetInviteCountResponse, error)
• type Result
  • func NewResult(userID *commonpb.UserId, serverID int, mismatch, cached bool) Result
  • func (r Result) Cached() bool
  • func (r Result) GetServerIndex() int
  • func (r Result) GetUserID() []byte
  • func (r Result) Mismatch() bool

Types

type ClusteredInviteClient

type ClusteredInviteClient struct {
	// contains filtered or unexported fields
}

func NewClusteredInviteClient

func NewClusteredInviteClient(cc grpc.ClientConnInterface) *ClusteredInviteClient

func (*ClusteredInviteClient) GetInvitationStatus

func (c *ClusteredInviteClient) GetInvitationStatus(ctx context.Context, in *invitepb.GetInvitationStatusRequest, opts ...grpc.CallOption) (*invitepb.GetInvitationStatusResponse, error)

func (*ClusteredInviteClient) GetInviteCount

func (c *ClusteredInviteClient) GetInviteCount(ctx context.Context, in *invitepb.GetInviteCountRequest, opts ...grpc.CallOption) (*invitepb.GetInviteCountResponse, error)

func (*ClusteredInviteClient) InvitePhoneNumber

func (c *ClusteredInviteClient) InvitePhoneNumber(ctx context.Context, in *invitepb.InvitePhoneNumberRequest, opts ...grpc.CallOption) (*invitepb.InvitePhoneNumberResponse, error)

type ClusteredInviteService

type ClusteredInviteService struct {
	invitepb.UnimplementedInviteServer
	// contains filtered or unexported fields
}

func NewClusteredInviteService

func NewClusteredInviteService(
	nodeID string,
	serverID int,
	registry registry.Observer,
	forwardingClientProvider func() invitepb.InviteClient,
) *ClusteredInviteService

func (*ClusteredInviteService) Close

func (c *ClusteredInviteService) Close()

func (*ClusteredInviteService) GetInviteCount

func (c *ClusteredInviteService) GetInviteCount(ctx context.Context, req *invitepb.GetInviteCountRequest) (*invitepb.GetInviteCountResponse, error)

type Result

type Result uint32

func NewResult

func NewResult(userID *commonpb.UserId, serverID int, mismatch, cached bool) Result

func (Result) Cached

func (r Result) Cached() bool

func (Result) GetServerIndex

func (r Result) GetServerIndex() int

func (Result) GetUserID

func (r Result) GetUserID() []byte

func (Result) Mismatch

func (r Result) Mismatch() bool