service

Documentation

Index

• Variables
• func RegisterLeaderElectionServiceServer(s *grpc.Server, srv LeaderElectionServiceServer)
• type LeaderElectionServiceClient
  • func NewLeaderElectionServiceClient(cc *grpc.ClientConn) LeaderElectionServiceClient
• type LeaderElectionServiceServer
• type LeaderElectionService_SubscribeOnLeaderClient
• type LeaderElectionService_SubscribeOnLeaderServer
• type SubscribeOnLeaderRequest
  • func (*SubscribeOnLeaderRequest) Descriptor() ([]byte, []int)
  • func (m *SubscribeOnLeaderRequest) Marshal() (dAtA []byte, err error)
  • func (m *SubscribeOnLeaderRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *SubscribeOnLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SubscribeOnLeaderRequest) ProtoMessage()
  • func (m *SubscribeOnLeaderRequest) Reset()
  • func (m *SubscribeOnLeaderRequest) Size() (n int)
  • func (m *SubscribeOnLeaderRequest) String() string
  • func (m *SubscribeOnLeaderRequest) Unmarshal(dAtA []byte) error
  • func (m *SubscribeOnLeaderRequest) XXX_DiscardUnknown()
  • func (m *SubscribeOnLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SubscribeOnLeaderRequest) XXX_Merge(src proto.Message)
  • func (m *SubscribeOnLeaderRequest) XXX_Size() int
  • func (m *SubscribeOnLeaderRequest) XXX_Unmarshal(b []byte) error
• type SubscribeOnLeaderResponse
  • func (*SubscribeOnLeaderResponse) Descriptor() ([]byte, []int)
  • func (m *SubscribeOnLeaderResponse) GetIsLeader() bool
  • func (m *SubscribeOnLeaderResponse) Marshal() (dAtA []byte, err error)
  • func (m *SubscribeOnLeaderResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *SubscribeOnLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SubscribeOnLeaderResponse) ProtoMessage()
  • func (m *SubscribeOnLeaderResponse) Reset()
  • func (m *SubscribeOnLeaderResponse) Size() (n int)
  • func (m *SubscribeOnLeaderResponse) String() string
  • func (m *SubscribeOnLeaderResponse) Unmarshal(dAtA []byte) error
  • func (m *SubscribeOnLeaderResponse) XXX_DiscardUnknown()
  • func (m *SubscribeOnLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SubscribeOnLeaderResponse) XXX_Merge(src proto.Message)
  • func (m *SubscribeOnLeaderResponse) XXX_Size() int
  • func (m *SubscribeOnLeaderResponse) XXX_Unmarshal(b []byte) error
• type UnimplementedLeaderElectionServiceServer
  • func (*UnimplementedLeaderElectionServiceServer) SubscribeOnLeader(req *SubscribeOnLeaderRequest, ...) error

Variables

var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterLeaderElectionServiceServer

func RegisterLeaderElectionServiceServer(s *grpc.Server, srv LeaderElectionServiceServer)

Types

type LeaderElectionServiceClient

type LeaderElectionServiceClient interface {
	SubscribeOnLeader(ctx context.Context, in *SubscribeOnLeaderRequest, opts ...grpc.CallOption) (LeaderElectionService_SubscribeOnLeaderClient, error)
}

LeaderElectionServiceClient is the client API for LeaderElectionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLeaderElectionServiceClient

func NewLeaderElectionServiceClient(cc *grpc.ClientConn) LeaderElectionServiceClient

type LeaderElectionServiceServer

type LeaderElectionServiceServer interface {
	SubscribeOnLeader(*SubscribeOnLeaderRequest, LeaderElectionService_SubscribeOnLeaderServer) error
}

LeaderElectionServiceServer is the server API for LeaderElectionService service.

type LeaderElectionService_SubscribeOnLeaderClient

type LeaderElectionService_SubscribeOnLeaderClient interface {
	Recv() (*SubscribeOnLeaderResponse, error)
	grpc.ClientStream
}

type LeaderElectionService_SubscribeOnLeaderServer

type LeaderElectionService_SubscribeOnLeaderServer interface {
	Send(*SubscribeOnLeaderResponse) error
	grpc.ServerStream
}

type SubscribeOnLeaderRequest

type SubscribeOnLeaderRequest struct {
}

func (*SubscribeOnLeaderRequest) Descriptor

func (*SubscribeOnLeaderRequest) Descriptor() ([]byte, []int)

func (*SubscribeOnLeaderRequest) Marshal

func (m *SubscribeOnLeaderRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeOnLeaderRequest) MarshalTo

func (m *SubscribeOnLeaderRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeOnLeaderRequest) MarshalToSizedBuffer

func (m *SubscribeOnLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeOnLeaderRequest) ProtoMessage

func (*SubscribeOnLeaderRequest) ProtoMessage()

func (*SubscribeOnLeaderRequest) Reset

func (m *SubscribeOnLeaderRequest) Reset()

func (*SubscribeOnLeaderRequest) Size

func (m *SubscribeOnLeaderRequest) Size() (n int)

func (*SubscribeOnLeaderRequest) String

func (m *SubscribeOnLeaderRequest) String() string

func (*SubscribeOnLeaderRequest) Unmarshal

func (m *SubscribeOnLeaderRequest) Unmarshal(dAtA []byte) error

func (*SubscribeOnLeaderRequest) XXX_DiscardUnknown

func (m *SubscribeOnLeaderRequest) XXX_DiscardUnknown()

func (*SubscribeOnLeaderRequest) XXX_Marshal

func (m *SubscribeOnLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeOnLeaderRequest) XXX_Merge

func (m *SubscribeOnLeaderRequest) XXX_Merge(src proto.Message)

func (*SubscribeOnLeaderRequest) XXX_Size

func (m *SubscribeOnLeaderRequest) XXX_Size() int

func (*SubscribeOnLeaderRequest) XXX_Unmarshal

func (m *SubscribeOnLeaderRequest) XXX_Unmarshal(b []byte) error

type SubscribeOnLeaderResponse

type SubscribeOnLeaderResponse struct {
	IsLeader bool `protobuf:"varint,1,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
}

func (*SubscribeOnLeaderResponse) Descriptor

func (*SubscribeOnLeaderResponse) Descriptor() ([]byte, []int)

func (*SubscribeOnLeaderResponse) GetIsLeader

func (m *SubscribeOnLeaderResponse) GetIsLeader() bool

func (*SubscribeOnLeaderResponse) Marshal

func (m *SubscribeOnLeaderResponse) Marshal() (dAtA []byte, err error)

func (*SubscribeOnLeaderResponse) MarshalTo

func (m *SubscribeOnLeaderResponse) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeOnLeaderResponse) MarshalToSizedBuffer

func (m *SubscribeOnLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeOnLeaderResponse) ProtoMessage

func (*SubscribeOnLeaderResponse) ProtoMessage()

func (*SubscribeOnLeaderResponse) Reset

func (m *SubscribeOnLeaderResponse) Reset()

func (*SubscribeOnLeaderResponse) Size

func (m *SubscribeOnLeaderResponse) Size() (n int)

func (*SubscribeOnLeaderResponse) String

func (m *SubscribeOnLeaderResponse) String() string

func (*SubscribeOnLeaderResponse) Unmarshal

func (m *SubscribeOnLeaderResponse) Unmarshal(dAtA []byte) error

func (*SubscribeOnLeaderResponse) XXX_DiscardUnknown

func (m *SubscribeOnLeaderResponse) XXX_DiscardUnknown()

func (*SubscribeOnLeaderResponse) XXX_Marshal

func (m *SubscribeOnLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeOnLeaderResponse) XXX_Merge

func (m *SubscribeOnLeaderResponse) XXX_Merge(src proto.Message)

func (*SubscribeOnLeaderResponse) XXX_Size

func (m *SubscribeOnLeaderResponse) XXX_Size() int

func (*SubscribeOnLeaderResponse) XXX_Unmarshal

func (m *SubscribeOnLeaderResponse) XXX_Unmarshal(b []byte) error

type UnimplementedLeaderElectionServiceServer

type UnimplementedLeaderElectionServiceServer struct {
}

UnimplementedLeaderElectionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLeaderElectionServiceServer) SubscribeOnLeader

func (*UnimplementedLeaderElectionServiceServer) SubscribeOnLeader(req *SubscribeOnLeaderRequest, srv LeaderElectionService_SubscribeOnLeaderServer) error