leader

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthManager        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManager          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrimitive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrimitive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Event_Type_name = map[int32]string{
	0: "NONE",
	1: "CHANGE",
}
View Source 
var Event_Type_value = map[string]int32{
	"NONE":   0,
	"CHANGE": 1,
}

Functions

func RegisterLeaderLatchManagerServer added in v0.7.0 

func RegisterLeaderLatchManagerServer(s *grpc.Server, srv LeaderLatchManagerServer)

func RegisterLeaderLatchServer 

func RegisterLeaderLatchServer(s *grpc.Server, srv LeaderLatchServer)

Types

type CloseSessionRequest 

type CloseSessionRequest struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionID 

func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*CloseSessionRequest) Marshal 

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

func (*CloseSessionRequest) MarshalTo 

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

func (*CloseSessionRequest) MarshalToSizedBuffer 

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

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

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

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

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

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

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

func (*CloseSessionRequest) XXX_Merge 

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

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

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

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) Marshal 

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

func (*CloseSessionResponse) MarshalTo 

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

func (*CloseSessionResponse) MarshalToSizedBuffer 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

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

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

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

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

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

func (*CloseSessionResponse) XXX_Merge 

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

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

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

type Event 

type Event struct {
	Type  Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.leader.v1.Event_Type" json:"type,omitempty"`
	Latch Latch      `protobuf:"bytes,2,opt,name=latch,proto3" json:"latch"`
}

func (*Event) Descriptor 

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

func (*Event) GetLatch 

func (m *Event) GetLatch() Latch

func (*Event) GetType 

func (m *Event) GetType() Event_Type

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_Type 

type Event_Type int32
const (
	Event_NONE   Event_Type = 0
	Event_CHANGE Event_Type = 1
)

func (Event_Type) EnumDescriptor 

func (Event_Type) EnumDescriptor() ([]byte, []int)

func (Event_Type) String 

func (x Event_Type) String() string

type EventsRequest 

type EventsRequest struct {
}

func (*EventsRequest) Descriptor 

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

func (*EventsRequest) Marshal 

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

func (*EventsRequest) MarshalTo 

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

func (*EventsRequest) MarshalToSizedBuffer 

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

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset 

func (m *EventsRequest) Reset()

func (*EventsRequest) Size 

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

func (*EventsRequest) String 

func (m *EventsRequest) String() string

func (*EventsRequest) Unmarshal 

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

func (*EventsRequest) XXX_DiscardUnknown 

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal 

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

func (*EventsRequest) XXX_Merge 

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

func (*EventsRequest) XXX_Size 

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal 

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

type EventsResponse 

type EventsResponse struct {
	Event Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event"`
}

func (*EventsResponse) Descriptor 

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

func (*EventsResponse) GetEvent 

func (m *EventsResponse) GetEvent() Event

func (*EventsResponse) Marshal 

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

func (*EventsResponse) MarshalTo 

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

func (*EventsResponse) MarshalToSizedBuffer 

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

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) Size 

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

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal 

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

func (*EventsResponse) XXX_DiscardUnknown 

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal 

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

func (*EventsResponse) XXX_Merge 

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

func (*EventsResponse) XXX_Size 

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	Latch Latch `protobuf:"bytes,2,opt,name=latch,proto3" json:"latch"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetLatch 

func (m *GetResponse) GetLatch() Latch

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type Latch 

type Latch struct {
	v1.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Leader        string   `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	Participants  []string `protobuf:"bytes,3,rep,name=participants,proto3" json:"participants,omitempty"`
}

func (*Latch) Descriptor 

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

func (*Latch) GetLeader 

func (m *Latch) GetLeader() string

func (*Latch) GetParticipants 

func (m *Latch) GetParticipants() []string

func (*Latch) Marshal 

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

func (*Latch) MarshalTo 

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

func (*Latch) MarshalToSizedBuffer 

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

func (*Latch) ProtoMessage 

func (*Latch) ProtoMessage()

func (*Latch) Reset 

func (m *Latch) Reset()

func (*Latch) Size 

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

func (*Latch) String 

func (m *Latch) String() string

func (*Latch) Unmarshal 

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

func (*Latch) XXX_DiscardUnknown 

func (m *Latch) XXX_DiscardUnknown()

func (*Latch) XXX_Marshal 

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

func (*Latch) XXX_Merge 

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

func (*Latch) XXX_Size 

func (m *Latch) XXX_Size() int

func (*Latch) XXX_Unmarshal 

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

type LatchRequest 

type LatchRequest struct {
}

func (*LatchRequest) Descriptor 

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

func (*LatchRequest) Marshal 

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

func (*LatchRequest) MarshalTo 

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

func (*LatchRequest) MarshalToSizedBuffer 

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

func (*LatchRequest) ProtoMessage 

func (*LatchRequest) ProtoMessage()

func (*LatchRequest) Reset 

func (m *LatchRequest) Reset()

func (*LatchRequest) Size 

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

func (*LatchRequest) String 

func (m *LatchRequest) String() string

func (*LatchRequest) Unmarshal 

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

func (*LatchRequest) XXX_DiscardUnknown 

func (m *LatchRequest) XXX_DiscardUnknown()

func (*LatchRequest) XXX_Marshal 

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

func (*LatchRequest) XXX_Merge 

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

func (*LatchRequest) XXX_Size 

func (m *LatchRequest) XXX_Size() int

func (*LatchRequest) XXX_Unmarshal 

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

type LatchResponse 

type LatchResponse struct {
	Latch Latch `protobuf:"bytes,2,opt,name=latch,proto3" json:"latch"`
}

func (*LatchResponse) Descriptor 

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

func (*LatchResponse) GetLatch 

func (m *LatchResponse) GetLatch() Latch

func (*LatchResponse) Marshal 

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

func (*LatchResponse) MarshalTo 

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

func (*LatchResponse) MarshalToSizedBuffer 

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

func (*LatchResponse) ProtoMessage 

func (*LatchResponse) ProtoMessage()

func (*LatchResponse) Reset 

func (m *LatchResponse) Reset()

func (*LatchResponse) Size 

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

func (*LatchResponse) String 

func (m *LatchResponse) String() string

func (*LatchResponse) Unmarshal 

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

func (*LatchResponse) XXX_DiscardUnknown 

func (m *LatchResponse) XXX_DiscardUnknown()

func (*LatchResponse) XXX_Marshal 

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

func (*LatchResponse) XXX_Merge 

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

func (*LatchResponse) XXX_Size 

func (m *LatchResponse) XXX_Size() int

func (*LatchResponse) XXX_Unmarshal 

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

type LeaderLatchClient 

type LeaderLatchClient interface {
	// Latch attempts to acquire the leader latch
	Latch(ctx context.Context, in *LatchRequest, opts ...grpc.CallOption) (*LatchResponse, error)
	// Get gets the current leader
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Events listens for leader change events
	Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (LeaderLatch_EventsClient, error)
}

LeaderLatchClient is the client API for LeaderLatch service.

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

func NewLeaderLatchClient 

func NewLeaderLatchClient(cc *grpc.ClientConn) LeaderLatchClient

type LeaderLatchManagerClient added in v0.7.0 

type LeaderLatchManagerClient interface {
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

LeaderLatchManagerClient is the client API for LeaderLatchManager service.

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

func NewLeaderLatchManagerClient added in v0.7.0 

func NewLeaderLatchManagerClient(cc *grpc.ClientConn) LeaderLatchManagerClient

type LeaderLatchManagerServer added in v0.7.0 

type LeaderLatchManagerServer interface {
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
}

LeaderLatchManagerServer is the server API for LeaderLatchManager service.

type LeaderLatchServer 

type LeaderLatchServer interface {
	// Latch attempts to acquire the leader latch
	Latch(context.Context, *LatchRequest) (*LatchResponse, error)
	// Get gets the current leader
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Events listens for leader change events
	Events(*EventsRequest, LeaderLatch_EventsServer) error
}

LeaderLatchServer is the server API for LeaderLatch service.

type LeaderLatchSessionOptions 

type LeaderLatchSessionOptions struct {
}

func (*LeaderLatchSessionOptions) Descriptor 

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

func (*LeaderLatchSessionOptions) Marshal 

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

func (*LeaderLatchSessionOptions) MarshalTo 

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

func (*LeaderLatchSessionOptions) MarshalToSizedBuffer 

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

func (*LeaderLatchSessionOptions) ProtoMessage 

func (*LeaderLatchSessionOptions) ProtoMessage()

func (*LeaderLatchSessionOptions) Reset 

func (m *LeaderLatchSessionOptions) Reset()

func (*LeaderLatchSessionOptions) Size 

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

func (*LeaderLatchSessionOptions) String 

func (m *LeaderLatchSessionOptions) String() string

func (*LeaderLatchSessionOptions) Unmarshal 

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

func (*LeaderLatchSessionOptions) XXX_DiscardUnknown 

func (m *LeaderLatchSessionOptions) XXX_DiscardUnknown()

func (*LeaderLatchSessionOptions) XXX_Marshal 

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

func (*LeaderLatchSessionOptions) XXX_Merge 

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

func (*LeaderLatchSessionOptions) XXX_Size 

func (m *LeaderLatchSessionOptions) XXX_Size() int

func (*LeaderLatchSessionOptions) XXX_Unmarshal 

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

type LeaderLatch_EventsClient 

type LeaderLatch_EventsClient interface {
	Recv() (*EventsResponse, error)
	grpc.ClientStream
}

type LeaderLatch_EventsServer 

type LeaderLatch_EventsServer interface {
	Send(*EventsResponse) error
	grpc.ServerStream
}

type OpenSessionRequest 

type OpenSessionRequest struct {
	PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive_v1.ID `` /* 158-byte string literal not displayed */
	Options     LeaderLatchSessionOptions                              `protobuf:"bytes,2,opt,name=options,proto3" json:"options"`
}

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetOptions 

func (m *OpenSessionRequest) GetOptions() LeaderLatchSessionOptions

func (*OpenSessionRequest) GetPrimitiveID 

func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID

func (*OpenSessionRequest) Marshal 

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

func (*OpenSessionRequest) MarshalTo 

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

func (*OpenSessionRequest) MarshalToSizedBuffer 

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

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

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

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

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

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

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

func (*OpenSessionRequest) XXX_Merge 

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

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

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

type OpenSessionResponse 

type OpenSessionResponse struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSessionID 

func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*OpenSessionResponse) Marshal 

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

func (*OpenSessionResponse) MarshalTo 

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

func (*OpenSessionResponse) MarshalToSizedBuffer 

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

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

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

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

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

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

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

func (*OpenSessionResponse) XXX_Merge 

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

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

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

type UnimplementedLeaderLatchManagerServer added in v0.7.0 

type UnimplementedLeaderLatchManagerServer struct {
}

UnimplementedLeaderLatchManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedLeaderLatchManagerServer) CloseSession added in v0.7.0 

func (*UnimplementedLeaderLatchManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

func (*UnimplementedLeaderLatchManagerServer) OpenSession added in v0.7.0 

func (*UnimplementedLeaderLatchManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)

type UnimplementedLeaderLatchServer 

type UnimplementedLeaderLatchServer struct {
}

UnimplementedLeaderLatchServer can be embedded to have forward compatible implementations.

func (*UnimplementedLeaderLatchServer) Events 

func (*UnimplementedLeaderLatchServer) Events(req *EventsRequest, srv LeaderLatch_EventsServer) error

func (*UnimplementedLeaderLatchServer) Get 

func (*UnimplementedLeaderLatchServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedLeaderLatchServer) Latch 

func (*UnimplementedLeaderLatchServer) Latch(ctx context.Context, req *LatchRequest) (*LatchResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.