Documentation
¶
Index ¶
- Variables
- func RegisterAssignServer(s grpc.ServiceRegistrar, srv AssignServer)
- func RegisterClockServer(s grpc.ServiceRegistrar, srv ClockServer)
- type AssignClient
- type AssignServer
- type Case
- func (*Case) Descriptor() ([]byte, []int)
- func (m *Case) GetCaseID() int32
- func (*Case) ProtoMessage()
- func (m *Case) Reset()
- func (m *Case) String() string
- func (m *Case) XXX_DiscardUnknown()
- func (m *Case) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Case) XXX_Merge(src proto.Message)
- func (m *Case) XXX_Size() int
- func (m *Case) XXX_Unmarshal(b []byte) error
- type ClockClient
- type ClockServer
- type Clock_RegisterClient
- type Clock_RegisterServer
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetStatus() bool
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) String() string
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Response) XXX_Merge(src proto.Message)
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type Tick
- func (*Tick) Descriptor() ([]byte, []int)
- func (m *Tick) GetTickNum() int32
- func (*Tick) ProtoMessage()
- func (m *Tick) Reset()
- func (m *Tick) String() string
- func (m *Tick) XXX_DiscardUnknown()
- func (m *Tick) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Tick) XXX_Merge(src proto.Message)
- func (m *Tick) XXX_Size() int
- func (m *Tick) XXX_Unmarshal(b []byte) error
- type UnimplementedAssignServer
- type UnimplementedClockServer
- type UnsafeAssignServer
- type UnsafeClockServer
- type WorkerRegister
- func (*WorkerRegister) Descriptor() ([]byte, []int)
- func (m *WorkerRegister) GetID() string
- func (*WorkerRegister) ProtoMessage()
- func (m *WorkerRegister) Reset()
- func (m *WorkerRegister) String() string
- func (m *WorkerRegister) XXX_DiscardUnknown()
- func (m *WorkerRegister) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WorkerRegister) XXX_Merge(src proto.Message)
- func (m *WorkerRegister) XXX_Size() int
- func (m *WorkerRegister) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Assign_ServiceDesc = grpc.ServiceDesc{ ServiceName: "casemanagement.Assign", HandlerType: (*AssignServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Assign", Handler: _Assign_Assign_Handler, }, { MethodName: "UnAssign", Handler: _Assign_UnAssign_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "casemanagement.proto", }
Assign_ServiceDesc is the grpc.ServiceDesc for Assign service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
View Source
var Clock_ServiceDesc = grpc.ServiceDesc{ ServiceName: "clock.Clock", HandlerType: (*ClockServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Register", Handler: _Clock_Register_Handler, ServerStreams: true, }, }, Metadata: "clock.proto", }
Clock_ServiceDesc is the grpc.ServiceDesc for Clock service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAssignServer ¶
func RegisterAssignServer(s grpc.ServiceRegistrar, srv AssignServer)
func RegisterClockServer ¶
func RegisterClockServer(s grpc.ServiceRegistrar, srv ClockServer)
Types ¶
type AssignClient ¶
type AssignClient interface {
Assign(ctx context.Context, in *Case, opts ...grpc.CallOption) (*Response, error)
UnAssign(ctx context.Context, in *Case, opts ...grpc.CallOption) (*Response, error)
}
AssignClient is the client API for Assign service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAssignClient ¶
func NewAssignClient(cc grpc.ClientConnInterface) AssignClient
type AssignServer ¶
type AssignServer interface {
Assign(context.Context, *Case) (*Response, error)
UnAssign(context.Context, *Case) (*Response, error)
// contains filtered or unexported methods
}
AssignServer is the server API for Assign service. All implementations must embed UnimplementedAssignServer for forward compatibility
type Case ¶
type Case struct {
CaseID int32 `protobuf:"varint,1,opt,name=caseID,proto3" json:"caseID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Case) Descriptor ¶
func (*Case) ProtoMessage ¶
func (*Case) ProtoMessage()
func (*Case) XXX_DiscardUnknown ¶
func (m *Case) XXX_DiscardUnknown()
func (*Case) XXX_Unmarshal ¶
type ClockClient ¶
type ClockClient interface {
Register(ctx context.Context, in *WorkerRegister, opts ...grpc.CallOption) (Clock_RegisterClient, error)
}
ClockClient is the client API for Clock service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClockClient ¶
func NewClockClient(cc grpc.ClientConnInterface) ClockClient
type ClockServer ¶
type ClockServer interface {
Register(*WorkerRegister, Clock_RegisterServer) error
// contains filtered or unexported methods
}
ClockServer is the server API for Clock service. All implementations must embed UnimplementedClockServer for forward compatibility
type Clock_RegisterClient ¶
type Clock_RegisterClient interface {
Recv() (*Tick, error)
grpc.ClientStream
}
type Clock_RegisterServer ¶
type Clock_RegisterServer interface {
Send(*Tick) error
grpc.ServerStream
}
type Response ¶
type Response struct {
Status bool `protobuf:"varint,1,opt,name=Status,proto3" json:"Status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Response) Descriptor ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶
func (*Response) XXX_Unmarshal ¶
type Tick ¶
type Tick struct {
TickNum int32 `protobuf:"varint,1,opt,name=TickNum,proto3" json:"TickNum,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Tick) Descriptor ¶
func (*Tick) GetTickNum ¶
func (*Tick) ProtoMessage ¶
func (*Tick) ProtoMessage()
func (*Tick) XXX_DiscardUnknown ¶
func (m *Tick) XXX_DiscardUnknown()
func (*Tick) XXX_Unmarshal ¶
type UnimplementedAssignServer ¶
type UnimplementedAssignServer struct {
}
UnimplementedAssignServer must be embedded to have forward compatible implementations.
type UnimplementedClockServer ¶
type UnimplementedClockServer struct {
}
UnimplementedClockServer must be embedded to have forward compatible implementations.
func (UnimplementedClockServer) Register ¶
func (UnimplementedClockServer) Register(*WorkerRegister, Clock_RegisterServer) error
type UnsafeAssignServer ¶
type UnsafeAssignServer interface {
// contains filtered or unexported methods
}
UnsafeAssignServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AssignServer will result in compilation errors.
type UnsafeClockServer ¶
type UnsafeClockServer interface {
// contains filtered or unexported methods
}
UnsafeClockServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClockServer will result in compilation errors.
type WorkerRegister ¶
type WorkerRegister struct {
ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*WorkerRegister) Descriptor ¶
func (*WorkerRegister) Descriptor() ([]byte, []int)
func (*WorkerRegister) GetID ¶
func (m *WorkerRegister) GetID() string
func (*WorkerRegister) ProtoMessage ¶
func (*WorkerRegister) ProtoMessage()
func (*WorkerRegister) Reset ¶
func (m *WorkerRegister) Reset()
func (*WorkerRegister) String ¶
func (m *WorkerRegister) String() string
func (*WorkerRegister) XXX_DiscardUnknown ¶
func (m *WorkerRegister) XXX_DiscardUnknown()
func (*WorkerRegister) XXX_Marshal ¶
func (m *WorkerRegister) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkerRegister) XXX_Merge ¶
func (dst *WorkerRegister) XXX_Merge(src proto.Message)
func (*WorkerRegister) XXX_Size ¶
func (m *WorkerRegister) XXX_Size() int
func (*WorkerRegister) XXX_Unmarshal ¶
func (m *WorkerRegister) XXX_Unmarshal(b []byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.