Documentation
¶
Index ¶
- Variables
- func RegisterMeshsyncServer(s *grpc.Server, srv MeshsyncServer)
- type MeshsyncClient
- type MeshsyncServer
- type Request
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetError() *common.CommonError
- func (x *Response) GetMessage() string
- func (m *Response) GetResult() isResponse_Result
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type Response_Error
- type Response_Message
- type UnimplementedMeshsyncServer
- func (*UnimplementedMeshsyncServer) Health(context.Context, *empty.Empty) (*controller.ControllerHealth, error)
- func (*UnimplementedMeshsyncServer) Info(context.Context, *empty.Empty) (*controller.ControllerInfo, error)
- func (*UnimplementedMeshsyncServer) Sync(context.Context, *Request) (*Response, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var File_sync_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMeshsyncServer ¶
func RegisterMeshsyncServer(s *grpc.Server, srv MeshsyncServer)
Types ¶
type MeshsyncClient ¶
type MeshsyncClient interface {
Info(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*controller.ControllerInfo, error)
Health(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*controller.ControllerHealth, error)
Sync(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}
MeshsyncClient is the client API for Meshsync service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMeshsyncClient ¶
func NewMeshsyncClient(cc grpc.ClientConnInterface) MeshsyncClient
type MeshsyncServer ¶
type MeshsyncServer interface {
Info(context.Context, *empty.Empty) (*controller.ControllerInfo, error)
Health(context.Context, *empty.Empty) (*controller.ControllerHealth, error)
Sync(context.Context, *Request) (*Response, error)
}
MeshsyncServer is the server API for Meshsync service.
type Request ¶
type Request struct {
// contains filtered or unexported fields
}
Fingerprints can be added to have a dynamic functionality
func (*Request) Descriptor
deprecated
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type Response ¶
type Response struct {
// Types that are assignable to Result:
// *Response_Message
// *Response_Error
Result isResponse_Result `protobuf_oneof:"result"`
// contains filtered or unexported fields
}
func (*Response) Descriptor
deprecated
func (*Response) GetError ¶
func (x *Response) GetError() *common.CommonError
func (*Response) GetMessage ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Response_Error ¶
type Response_Error struct {
Error *common.CommonError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}
type Response_Message ¶
type Response_Message struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3,oneof"`
}
type UnimplementedMeshsyncServer ¶
type UnimplementedMeshsyncServer struct {
}
UnimplementedMeshsyncServer can be embedded to have forward compatible implementations.
func (*UnimplementedMeshsyncServer) Health ¶
func (*UnimplementedMeshsyncServer) Health(context.Context, *empty.Empty) (*controller.ControllerHealth, error)
func (*UnimplementedMeshsyncServer) Info ¶
func (*UnimplementedMeshsyncServer) Info(context.Context, *empty.Empty) (*controller.ControllerInfo, error)
Click to show internal directories.
Click to hide internal directories.