coordinator

package
v0.0.0-...-72c2bb7 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCoordinatorservicer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCoordinatorservicer   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterCoordinatorServer 

func RegisterCoordinatorServer(s *grpc.Server, srv CoordinatorServer)

Types

type CoordinatorClient 

type CoordinatorClient interface {
	StartGroup(ctx context.Context, in *StartGroupRequest, opts ...grpc.CallOption) (*GroupStartedResponse, error)
	StopGroup(ctx context.Context, in *StopGroupRequest, opts ...grpc.CallOption) (*GroupStoppedResponse, error)
}

CoordinatorClient is the client API for Coordinator service.

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

func NewCoordinatorClient 

func NewCoordinatorClient(cc *grpc.ClientConn) CoordinatorClient

type CoordinatorServer 

type CoordinatorServer interface {
	StartGroup(context.Context, *StartGroupRequest) (*GroupStartedResponse, error)
	StopGroup(context.Context, *StopGroupRequest) (*GroupStoppedResponse, error)
}

CoordinatorServer is the server API for Coordinator service.

type GroupStartedResponse 

type GroupStartedResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GroupStartedResponse) Descriptor 

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

func (*GroupStartedResponse) Marshal 

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

func (*GroupStartedResponse) MarshalTo 

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

func (*GroupStartedResponse) ProtoMessage 

func (*GroupStartedResponse) ProtoMessage()

func (*GroupStartedResponse) Reset 

func (m *GroupStartedResponse) Reset()

func (*GroupStartedResponse) Size 

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

func (*GroupStartedResponse) String 

func (m *GroupStartedResponse) String() string

func (*GroupStartedResponse) Unmarshal 

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

func (*GroupStartedResponse) XXX_DiscardUnknown 

func (m *GroupStartedResponse) XXX_DiscardUnknown()

func (*GroupStartedResponse) XXX_Marshal 

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

func (*GroupStartedResponse) XXX_Merge 

func (dst *GroupStartedResponse) XXX_Merge(src proto.Message)

func (*GroupStartedResponse) XXX_Size 

func (m *GroupStartedResponse) XXX_Size() int

func (*GroupStartedResponse) XXX_Unmarshal 

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

type GroupStoppedResponse 

type GroupStoppedResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GroupStoppedResponse) Descriptor 

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

func (*GroupStoppedResponse) GetMessage 

func (m *GroupStoppedResponse) GetMessage() string

func (*GroupStoppedResponse) Marshal 

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

func (*GroupStoppedResponse) MarshalTo 

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

func (*GroupStoppedResponse) ProtoMessage 

func (*GroupStoppedResponse) ProtoMessage()

func (*GroupStoppedResponse) Reset 

func (m *GroupStoppedResponse) Reset()

func (*GroupStoppedResponse) Size 

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

func (*GroupStoppedResponse) String 

func (m *GroupStoppedResponse) String() string

func (*GroupStoppedResponse) Unmarshal 

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

func (*GroupStoppedResponse) XXX_DiscardUnknown 

func (m *GroupStoppedResponse) XXX_DiscardUnknown()

func (*GroupStoppedResponse) XXX_Marshal 

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

func (*GroupStoppedResponse) XXX_Merge 

func (dst *GroupStoppedResponse) XXX_Merge(src proto.Message)

func (*GroupStoppedResponse) XXX_Size 

func (m *GroupStoppedResponse) XXX_Size() int

func (*GroupStoppedResponse) XXX_Unmarshal 

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

type StartGroupRequest 

type StartGroupRequest struct {
	UserContext          *prototypes.UserContext `protobuf:"bytes,1,opt,name=UserContext" json:"UserContext,omitempty"`
	GroupID              int32                   `protobuf:"varint,2,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	OrgID                int32                   `protobuf:"varint,3,opt,name=OrgID,proto3" json:"OrgID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*StartGroupRequest) Descriptor 

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

func (*StartGroupRequest) GetGroupID 

func (m *StartGroupRequest) GetGroupID() int32

func (*StartGroupRequest) GetOrgID 

func (m *StartGroupRequest) GetOrgID() int32

func (*StartGroupRequest) GetUserContext 

func (m *StartGroupRequest) GetUserContext() *prototypes.UserContext

func (*StartGroupRequest) Marshal 

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

func (*StartGroupRequest) MarshalTo 

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

func (*StartGroupRequest) ProtoMessage 

func (*StartGroupRequest) ProtoMessage()

func (*StartGroupRequest) Reset 

func (m *StartGroupRequest) Reset()

func (*StartGroupRequest) Size 

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

func (*StartGroupRequest) String 

func (m *StartGroupRequest) String() string

func (*StartGroupRequest) Unmarshal 

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

func (*StartGroupRequest) XXX_DiscardUnknown 

func (m *StartGroupRequest) XXX_DiscardUnknown()

func (*StartGroupRequest) XXX_Marshal 

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

func (*StartGroupRequest) XXX_Merge 

func (dst *StartGroupRequest) XXX_Merge(src proto.Message)

func (*StartGroupRequest) XXX_Size 

func (m *StartGroupRequest) XXX_Size() int

func (*StartGroupRequest) XXX_Unmarshal 

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

type StopGroupRequest 

type StopGroupRequest struct {
	UserContext          *prototypes.UserContext `protobuf:"bytes,1,opt,name=UserContext" json:"UserContext,omitempty"`
	GroupID              int32                   `protobuf:"varint,2,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	OrgID                int32                   `protobuf:"varint,3,opt,name=OrgID,proto3" json:"OrgID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*StopGroupRequest) Descriptor 

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

func (*StopGroupRequest) GetGroupID 

func (m *StopGroupRequest) GetGroupID() int32

func (*StopGroupRequest) GetOrgID 

func (m *StopGroupRequest) GetOrgID() int32

func (*StopGroupRequest) GetUserContext 

func (m *StopGroupRequest) GetUserContext() *prototypes.UserContext

func (*StopGroupRequest) Marshal 

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

func (*StopGroupRequest) MarshalTo 

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

func (*StopGroupRequest) ProtoMessage 

func (*StopGroupRequest) ProtoMessage()

func (*StopGroupRequest) Reset 

func (m *StopGroupRequest) Reset()

func (*StopGroupRequest) Size 

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

func (*StopGroupRequest) String 

func (m *StopGroupRequest) String() string

func (*StopGroupRequest) Unmarshal 

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

func (*StopGroupRequest) XXX_DiscardUnknown 

func (m *StopGroupRequest) XXX_DiscardUnknown()

func (*StopGroupRequest) XXX_Marshal 

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

func (*StopGroupRequest) XXX_Merge 

func (dst *StopGroupRequest) XXX_Merge(src proto.Message)

func (*StopGroupRequest) XXX_Size 

func (m *StopGroupRequest) XXX_Size() int

func (*StopGroupRequest) XXX_Unmarshal 

func (m *StopGroupRequest) XXX_Unmarshal(b []byte) 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.