Documentation ¶
Index ¶
- Variables
- func ErrNoMasterInfoConfig(format string, a ...interface{}) error
- func IsErrNoMasterInfoConfig(err error) bool
- func RegisterCanalHTTPServer(s *http.Server, srv CanalHTTPServer)
- func RegisterCanalServer(s grpc.ServiceRegistrar, srv CanalServer)
- type CanalClient
- type CanalHTTPClient
- type CanalHTTPClientImpl
- func (c *CanalHTTPClientImpl) CheckMaster(ctx context.Context, in *CheckMasterRequest, opts ...http.CallOption) (*CheckMasterReply, error)
- func (c *CanalHTTPClientImpl) Errors(ctx context.Context, in *ErrorsRequest, opts ...http.CallOption) (*ErrorsReply, error)
- func (c *CanalHTTPClientImpl) InfocCurrent(ctx context.Context, in *InfocCurrentRequest, opts ...http.CallOption) (*InfocCurrentReply, error)
- func (c *CanalHTTPClientImpl) InfocPost(ctx context.Context, in *InfocPostRequest, opts ...http.CallOption) (*InfocPostReply, error)
- func (c *CanalHTTPClientImpl) SyncPos(ctx context.Context, in *SyncPosRequest, opts ...http.CallOption) (*SyncPosReply, error)
- type CanalHTTPServer
- type CanalServer
- type CheckMasterReply
- func (*CheckMasterReply) Descriptor() ([]byte, []int)deprecated
- func (x *CheckMasterReply) GetName() string
- func (x *CheckMasterReply) GetPos() int64
- func (*CheckMasterReply) ProtoMessage()
- func (x *CheckMasterReply) ProtoReflect() protoreflect.Message
- func (x *CheckMasterReply) Reset()
- func (x *CheckMasterReply) String() string
- func (m *CheckMasterReply) Validate() error
- type CheckMasterReplyValidationError
- func (e CheckMasterReplyValidationError) Cause() error
- func (e CheckMasterReplyValidationError) Error() string
- func (e CheckMasterReplyValidationError) ErrorName() string
- func (e CheckMasterReplyValidationError) Field() string
- func (e CheckMasterReplyValidationError) Key() bool
- func (e CheckMasterReplyValidationError) Reason() string
- type CheckMasterRequest
- func (*CheckMasterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckMasterRequest) GetAddr() string
- func (x *CheckMasterRequest) GetPassword() string
- func (x *CheckMasterRequest) GetUser() string
- func (*CheckMasterRequest) ProtoMessage()
- func (x *CheckMasterRequest) ProtoReflect() protoreflect.Message
- func (x *CheckMasterRequest) Reset()
- func (x *CheckMasterRequest) String() string
- func (m *CheckMasterRequest) Validate() error
- type CheckMasterRequestValidationError
- func (e CheckMasterRequestValidationError) Cause() error
- func (e CheckMasterRequestValidationError) Error() string
- func (e CheckMasterRequestValidationError) ErrorName() string
- func (e CheckMasterRequestValidationError) Field() string
- func (e CheckMasterRequestValidationError) Key() bool
- func (e CheckMasterRequestValidationError) Reason() string
- type ErrorsReply
- func (*ErrorsReply) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorsReply) GetError() string
- func (x *ErrorsReply) GetInstanceError() map[string]string
- func (*ErrorsReply) ProtoMessage()
- func (x *ErrorsReply) ProtoReflect() protoreflect.Message
- func (x *ErrorsReply) Reset()
- func (x *ErrorsReply) String() string
- func (m *ErrorsReply) Validate() error
- type ErrorsReplyValidationError
- func (e ErrorsReplyValidationError) Cause() error
- func (e ErrorsReplyValidationError) Error() string
- func (e ErrorsReplyValidationError) ErrorName() string
- func (e ErrorsReplyValidationError) Field() string
- func (e ErrorsReplyValidationError) Key() bool
- func (e ErrorsReplyValidationError) Reason() string
- type ErrorsRequest
- type ErrorsRequestValidationError
- func (e ErrorsRequestValidationError) Cause() error
- func (e ErrorsRequestValidationError) Error() string
- func (e ErrorsRequestValidationError) ErrorName() string
- func (e ErrorsRequestValidationError) Field() string
- func (e ErrorsRequestValidationError) Key() bool
- func (e ErrorsRequestValidationError) Reason() string
- type InfocConf
- type InfocConfValidationError
- type InfocCurrentReply
- type InfocCurrentReplyValidationError
- func (e InfocCurrentReplyValidationError) Cause() error
- func (e InfocCurrentReplyValidationError) Error() string
- func (e InfocCurrentReplyValidationError) ErrorName() string
- func (e InfocCurrentReplyValidationError) Field() string
- func (e InfocCurrentReplyValidationError) Key() bool
- func (e InfocCurrentReplyValidationError) Reason() string
- type InfocCurrentRequest
- func (*InfocCurrentRequest) Descriptor() ([]byte, []int)deprecated
- func (*InfocCurrentRequest) ProtoMessage()
- func (x *InfocCurrentRequest) ProtoReflect() protoreflect.Message
- func (x *InfocCurrentRequest) Reset()
- func (x *InfocCurrentRequest) String() string
- func (m *InfocCurrentRequest) Validate() error
- type InfocCurrentRequestValidationError
- func (e InfocCurrentRequestValidationError) Cause() error
- func (e InfocCurrentRequestValidationError) Error() string
- func (e InfocCurrentRequestValidationError) ErrorName() string
- func (e InfocCurrentRequestValidationError) Field() string
- func (e InfocCurrentRequestValidationError) Key() bool
- func (e InfocCurrentRequestValidationError) Reason() string
- type InfocPostReply
- type InfocPostReplyValidationError
- func (e InfocPostReplyValidationError) Cause() error
- func (e InfocPostReplyValidationError) Error() string
- func (e InfocPostReplyValidationError) ErrorName() string
- func (e InfocPostReplyValidationError) Field() string
- func (e InfocPostReplyValidationError) Key() bool
- func (e InfocPostReplyValidationError) Reason() string
- type InfocPostRequest
- func (*InfocPostRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InfocPostRequest) GetIcs() []*InfocConf
- func (*InfocPostRequest) ProtoMessage()
- func (x *InfocPostRequest) ProtoReflect() protoreflect.Message
- func (x *InfocPostRequest) Reset()
- func (x *InfocPostRequest) String() string
- func (m *InfocPostRequest) Validate() error
- type InfocPostRequestValidationError
- func (e InfocPostRequestValidationError) Cause() error
- func (e InfocPostRequestValidationError) Error() string
- func (e InfocPostRequestValidationError) ErrorName() string
- func (e InfocPostRequestValidationError) Field() string
- func (e InfocPostRequestValidationError) Key() bool
- func (e InfocPostRequestValidationError) Reason() string
- type SyncPosReply
- type SyncPosReplyValidationError
- func (e SyncPosReplyValidationError) Cause() error
- func (e SyncPosReplyValidationError) Error() string
- func (e SyncPosReplyValidationError) ErrorName() string
- func (e SyncPosReplyValidationError) Field() string
- func (e SyncPosReplyValidationError) Key() bool
- func (e SyncPosReplyValidationError) Reason() string
- type SyncPosRequest
- func (*SyncPosRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncPosRequest) GetAddr() string
- func (*SyncPosRequest) ProtoMessage()
- func (x *SyncPosRequest) ProtoReflect() protoreflect.Message
- func (x *SyncPosRequest) Reset()
- func (x *SyncPosRequest) String() string
- func (m *SyncPosRequest) Validate() error
- type SyncPosRequestValidationError
- func (e SyncPosRequestValidationError) Cause() error
- func (e SyncPosRequestValidationError) Error() string
- func (e SyncPosRequestValidationError) ErrorName() string
- func (e SyncPosRequestValidationError) Field() string
- func (e SyncPosRequestValidationError) Key() bool
- func (e SyncPosRequestValidationError) Reason() string
- type UnimplementedCanalServer
- func (UnimplementedCanalServer) CheckMaster(context.Context, *CheckMasterRequest) (*CheckMasterReply, error)
- func (UnimplementedCanalServer) Errors(context.Context, *ErrorsRequest) (*ErrorsReply, error)
- func (UnimplementedCanalServer) InfocCurrent(context.Context, *InfocCurrentRequest) (*InfocCurrentReply, error)
- func (UnimplementedCanalServer) InfocPost(context.Context, *InfocPostRequest) (*InfocPostReply, error)
- func (UnimplementedCanalServer) SyncPos(context.Context, *SyncPosRequest) (*SyncPosReply, error)
- type UnsafeCanalServer
Constants ¶
This section is empty.
Variables ¶
var Canal_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.canal.Canal", HandlerType: (*CanalServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "InfocPost", Handler: _Canal_InfocPost_Handler, }, { MethodName: "InfocCurrent", Handler: _Canal_InfocCurrent_Handler, }, { MethodName: "Errors", Handler: _Canal_Errors_Handler, }, { MethodName: "CheckMaster", Handler: _Canal_CheckMaster_Handler, }, { MethodName: "SyncPos", Handler: _Canal_SyncPos_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/canal/canal.proto", }
Canal_ServiceDesc is the grpc.ServiceDesc for Canal service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_api_canal_canal_proto protoreflect.FileDescriptor
Functions ¶
func ErrNoMasterInfoConfig ¶
func IsErrNoMasterInfoConfig ¶
func RegisterCanalHTTPServer ¶
func RegisterCanalHTTPServer(s *http.Server, srv CanalHTTPServer)
func RegisterCanalServer ¶
func RegisterCanalServer(s grpc.ServiceRegistrar, srv CanalServer)
Types ¶
type CanalClient ¶
type CanalClient interface { InfocPost(ctx context.Context, in *InfocPostRequest, opts ...grpc.CallOption) (*InfocPostReply, error) InfocCurrent(ctx context.Context, in *InfocCurrentRequest, opts ...grpc.CallOption) (*InfocCurrentReply, error) Errors(ctx context.Context, in *ErrorsRequest, opts ...grpc.CallOption) (*ErrorsReply, error) CheckMaster(ctx context.Context, in *CheckMasterRequest, opts ...grpc.CallOption) (*CheckMasterReply, error) SyncPos(ctx context.Context, in *SyncPosRequest, opts ...grpc.CallOption) (*SyncPosReply, error) }
CanalClient is the client API for Canal 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 NewCanalClient ¶
func NewCanalClient(cc grpc.ClientConnInterface) CanalClient
type CanalHTTPClient ¶
type CanalHTTPClient interface { CheckMaster(ctx context.Context, req *CheckMasterRequest, opts ...http.CallOption) (rsp *CheckMasterReply, err error) Errors(ctx context.Context, req *ErrorsRequest, opts ...http.CallOption) (rsp *ErrorsReply, err error) InfocCurrent(ctx context.Context, req *InfocCurrentRequest, opts ...http.CallOption) (rsp *InfocCurrentReply, err error) InfocPost(ctx context.Context, req *InfocPostRequest, opts ...http.CallOption) (rsp *InfocPostReply, err error) SyncPos(ctx context.Context, req *SyncPosRequest, opts ...http.CallOption) (rsp *SyncPosReply, err error) }
func NewCanalHTTPClient ¶
func NewCanalHTTPClient(client *http.Client) CanalHTTPClient
type CanalHTTPClientImpl ¶
type CanalHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*CanalHTTPClientImpl) CheckMaster ¶
func (c *CanalHTTPClientImpl) CheckMaster(ctx context.Context, in *CheckMasterRequest, opts ...http.CallOption) (*CheckMasterReply, error)
func (*CanalHTTPClientImpl) Errors ¶
func (c *CanalHTTPClientImpl) Errors(ctx context.Context, in *ErrorsRequest, opts ...http.CallOption) (*ErrorsReply, error)
func (*CanalHTTPClientImpl) InfocCurrent ¶
func (c *CanalHTTPClientImpl) InfocCurrent(ctx context.Context, in *InfocCurrentRequest, opts ...http.CallOption) (*InfocCurrentReply, error)
func (*CanalHTTPClientImpl) InfocPost ¶
func (c *CanalHTTPClientImpl) InfocPost(ctx context.Context, in *InfocPostRequest, opts ...http.CallOption) (*InfocPostReply, error)
func (*CanalHTTPClientImpl) SyncPos ¶
func (c *CanalHTTPClientImpl) SyncPos(ctx context.Context, in *SyncPosRequest, opts ...http.CallOption) (*SyncPosReply, error)
type CanalHTTPServer ¶
type CanalHTTPServer interface { CheckMaster(context.Context, *CheckMasterRequest) (*CheckMasterReply, error) Errors(context.Context, *ErrorsRequest) (*ErrorsReply, error) InfocCurrent(context.Context, *InfocCurrentRequest) (*InfocCurrentReply, error) InfocPost(context.Context, *InfocPostRequest) (*InfocPostReply, error) SyncPos(context.Context, *SyncPosRequest) (*SyncPosReply, error) }
type CanalServer ¶
type CanalServer interface { InfocPost(context.Context, *InfocPostRequest) (*InfocPostReply, error) InfocCurrent(context.Context, *InfocCurrentRequest) (*InfocCurrentReply, error) Errors(context.Context, *ErrorsRequest) (*ErrorsReply, error) CheckMaster(context.Context, *CheckMasterRequest) (*CheckMasterReply, error) SyncPos(context.Context, *SyncPosRequest) (*SyncPosReply, error) // contains filtered or unexported methods }
CanalServer is the server API for Canal service. All implementations must embed UnimplementedCanalServer for forward compatibility
type CheckMasterReply ¶
type CheckMasterReply struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Pos int64 `protobuf:"varint,2,opt,name=pos,proto3" json:"pos,omitempty"` // contains filtered or unexported fields }
func (*CheckMasterReply) Descriptor
deprecated
func (*CheckMasterReply) Descriptor() ([]byte, []int)
Deprecated: Use CheckMasterReply.ProtoReflect.Descriptor instead.
func (*CheckMasterReply) GetName ¶
func (x *CheckMasterReply) GetName() string
func (*CheckMasterReply) GetPos ¶
func (x *CheckMasterReply) GetPos() int64
func (*CheckMasterReply) ProtoMessage ¶
func (*CheckMasterReply) ProtoMessage()
func (*CheckMasterReply) ProtoReflect ¶
func (x *CheckMasterReply) ProtoReflect() protoreflect.Message
func (*CheckMasterReply) Reset ¶
func (x *CheckMasterReply) Reset()
func (*CheckMasterReply) String ¶
func (x *CheckMasterReply) String() string
func (*CheckMasterReply) Validate ¶
func (m *CheckMasterReply) Validate() error
Validate checks the field values on CheckMasterReply with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type CheckMasterReplyValidationError ¶
type CheckMasterReplyValidationError struct {
// contains filtered or unexported fields
}
CheckMasterReplyValidationError is the validation error returned by CheckMasterReply.Validate if the designated constraints aren't met.
func (CheckMasterReplyValidationError) Cause ¶
func (e CheckMasterReplyValidationError) Cause() error
Cause function returns cause value.
func (CheckMasterReplyValidationError) Error ¶
func (e CheckMasterReplyValidationError) Error() string
Error satisfies the builtin error interface
func (CheckMasterReplyValidationError) ErrorName ¶
func (e CheckMasterReplyValidationError) ErrorName() string
ErrorName returns error name.
func (CheckMasterReplyValidationError) Field ¶
func (e CheckMasterReplyValidationError) Field() string
Field function returns field value.
func (CheckMasterReplyValidationError) Key ¶
func (e CheckMasterReplyValidationError) Key() bool
Key function returns key value.
func (CheckMasterReplyValidationError) Reason ¶
func (e CheckMasterReplyValidationError) Reason() string
Reason function returns reason value.
type CheckMasterRequest ¶
type CheckMasterRequest struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*CheckMasterRequest) Descriptor
deprecated
func (*CheckMasterRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckMasterRequest.ProtoReflect.Descriptor instead.
func (*CheckMasterRequest) GetAddr ¶
func (x *CheckMasterRequest) GetAddr() string
func (*CheckMasterRequest) GetPassword ¶
func (x *CheckMasterRequest) GetPassword() string
func (*CheckMasterRequest) GetUser ¶
func (x *CheckMasterRequest) GetUser() string
func (*CheckMasterRequest) ProtoMessage ¶
func (*CheckMasterRequest) ProtoMessage()
func (*CheckMasterRequest) ProtoReflect ¶
func (x *CheckMasterRequest) ProtoReflect() protoreflect.Message
func (*CheckMasterRequest) Reset ¶
func (x *CheckMasterRequest) Reset()
func (*CheckMasterRequest) String ¶
func (x *CheckMasterRequest) String() string
func (*CheckMasterRequest) Validate ¶
func (m *CheckMasterRequest) Validate() error
Validate checks the field values on CheckMasterRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type CheckMasterRequestValidationError ¶
type CheckMasterRequestValidationError struct {
// contains filtered or unexported fields
}
CheckMasterRequestValidationError is the validation error returned by CheckMasterRequest.Validate if the designated constraints aren't met.
func (CheckMasterRequestValidationError) Cause ¶
func (e CheckMasterRequestValidationError) Cause() error
Cause function returns cause value.
func (CheckMasterRequestValidationError) Error ¶
func (e CheckMasterRequestValidationError) Error() string
Error satisfies the builtin error interface
func (CheckMasterRequestValidationError) ErrorName ¶
func (e CheckMasterRequestValidationError) ErrorName() string
ErrorName returns error name.
func (CheckMasterRequestValidationError) Field ¶
func (e CheckMasterRequestValidationError) Field() string
Field function returns field value.
func (CheckMasterRequestValidationError) Key ¶
func (e CheckMasterRequestValidationError) Key() bool
Key function returns key value.
func (CheckMasterRequestValidationError) Reason ¶
func (e CheckMasterRequestValidationError) Reason() string
Reason function returns reason value.
type ErrorsReply ¶
type ErrorsReply struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` InstanceError map[string]string `` /* 167-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ErrorsReply) Descriptor
deprecated
func (*ErrorsReply) Descriptor() ([]byte, []int)
Deprecated: Use ErrorsReply.ProtoReflect.Descriptor instead.
func (*ErrorsReply) GetError ¶
func (x *ErrorsReply) GetError() string
func (*ErrorsReply) GetInstanceError ¶
func (x *ErrorsReply) GetInstanceError() map[string]string
func (*ErrorsReply) ProtoMessage ¶
func (*ErrorsReply) ProtoMessage()
func (*ErrorsReply) ProtoReflect ¶
func (x *ErrorsReply) ProtoReflect() protoreflect.Message
func (*ErrorsReply) Reset ¶
func (x *ErrorsReply) Reset()
func (*ErrorsReply) String ¶
func (x *ErrorsReply) String() string
func (*ErrorsReply) Validate ¶
func (m *ErrorsReply) Validate() error
Validate checks the field values on ErrorsReply with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type ErrorsReplyValidationError ¶
type ErrorsReplyValidationError struct {
// contains filtered or unexported fields
}
ErrorsReplyValidationError is the validation error returned by ErrorsReply.Validate if the designated constraints aren't met.
func (ErrorsReplyValidationError) Cause ¶
func (e ErrorsReplyValidationError) Cause() error
Cause function returns cause value.
func (ErrorsReplyValidationError) Error ¶
func (e ErrorsReplyValidationError) Error() string
Error satisfies the builtin error interface
func (ErrorsReplyValidationError) ErrorName ¶
func (e ErrorsReplyValidationError) ErrorName() string
ErrorName returns error name.
func (ErrorsReplyValidationError) Field ¶
func (e ErrorsReplyValidationError) Field() string
Field function returns field value.
func (ErrorsReplyValidationError) Key ¶
func (e ErrorsReplyValidationError) Key() bool
Key function returns key value.
func (ErrorsReplyValidationError) Reason ¶
func (e ErrorsReplyValidationError) Reason() string
Reason function returns reason value.
type ErrorsRequest ¶
type ErrorsRequest struct {
// contains filtered or unexported fields
}
func (*ErrorsRequest) Descriptor
deprecated
func (*ErrorsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ErrorsRequest.ProtoReflect.Descriptor instead.
func (*ErrorsRequest) ProtoMessage ¶
func (*ErrorsRequest) ProtoMessage()
func (*ErrorsRequest) ProtoReflect ¶
func (x *ErrorsRequest) ProtoReflect() protoreflect.Message
func (*ErrorsRequest) Reset ¶
func (x *ErrorsRequest) Reset()
func (*ErrorsRequest) String ¶
func (x *ErrorsRequest) String() string
func (*ErrorsRequest) Validate ¶
func (m *ErrorsRequest) Validate() error
Validate checks the field values on ErrorsRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type ErrorsRequestValidationError ¶
type ErrorsRequestValidationError struct {
// contains filtered or unexported fields
}
ErrorsRequestValidationError is the validation error returned by ErrorsRequest.Validate if the designated constraints aren't met.
func (ErrorsRequestValidationError) Cause ¶
func (e ErrorsRequestValidationError) Cause() error
Cause function returns cause value.
func (ErrorsRequestValidationError) Error ¶
func (e ErrorsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ErrorsRequestValidationError) ErrorName ¶
func (e ErrorsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ErrorsRequestValidationError) Field ¶
func (e ErrorsRequestValidationError) Field() string
Field function returns field value.
func (ErrorsRequestValidationError) Key ¶
func (e ErrorsRequestValidationError) Key() bool
Key function returns key value.
func (ErrorsRequestValidationError) Reason ¶
func (e ErrorsRequestValidationError) Reason() string
Reason function returns reason value.
type InfocConf ¶
type InfocConf struct {
// contains filtered or unexported fields
}
func (*InfocConf) Descriptor
deprecated
func (*InfocConf) ProtoMessage ¶
func (*InfocConf) ProtoMessage()
func (*InfocConf) ProtoReflect ¶
func (x *InfocConf) ProtoReflect() protoreflect.Message
type InfocConfValidationError ¶
type InfocConfValidationError struct {
// contains filtered or unexported fields
}
InfocConfValidationError is the validation error returned by InfocConf.Validate if the designated constraints aren't met.
func (InfocConfValidationError) Cause ¶
func (e InfocConfValidationError) Cause() error
Cause function returns cause value.
func (InfocConfValidationError) Error ¶
func (e InfocConfValidationError) Error() string
Error satisfies the builtin error interface
func (InfocConfValidationError) ErrorName ¶
func (e InfocConfValidationError) ErrorName() string
ErrorName returns error name.
func (InfocConfValidationError) Field ¶
func (e InfocConfValidationError) Field() string
Field function returns field value.
func (InfocConfValidationError) Key ¶
func (e InfocConfValidationError) Key() bool
Key function returns key value.
func (InfocConfValidationError) Reason ¶
func (e InfocConfValidationError) Reason() string
Reason function returns reason value.
type InfocCurrentReply ¶
type InfocCurrentReply struct {
// contains filtered or unexported fields
}
func (*InfocCurrentReply) Descriptor
deprecated
func (*InfocCurrentReply) Descriptor() ([]byte, []int)
Deprecated: Use InfocCurrentReply.ProtoReflect.Descriptor instead.
func (*InfocCurrentReply) ProtoMessage ¶
func (*InfocCurrentReply) ProtoMessage()
func (*InfocCurrentReply) ProtoReflect ¶
func (x *InfocCurrentReply) ProtoReflect() protoreflect.Message
func (*InfocCurrentReply) Reset ¶
func (x *InfocCurrentReply) Reset()
func (*InfocCurrentReply) String ¶
func (x *InfocCurrentReply) String() string
func (*InfocCurrentReply) Validate ¶
func (m *InfocCurrentReply) Validate() error
Validate checks the field values on InfocCurrentReply with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type InfocCurrentReplyValidationError ¶
type InfocCurrentReplyValidationError struct {
// contains filtered or unexported fields
}
InfocCurrentReplyValidationError is the validation error returned by InfocCurrentReply.Validate if the designated constraints aren't met.
func (InfocCurrentReplyValidationError) Cause ¶
func (e InfocCurrentReplyValidationError) Cause() error
Cause function returns cause value.
func (InfocCurrentReplyValidationError) Error ¶
func (e InfocCurrentReplyValidationError) Error() string
Error satisfies the builtin error interface
func (InfocCurrentReplyValidationError) ErrorName ¶
func (e InfocCurrentReplyValidationError) ErrorName() string
ErrorName returns error name.
func (InfocCurrentReplyValidationError) Field ¶
func (e InfocCurrentReplyValidationError) Field() string
Field function returns field value.
func (InfocCurrentReplyValidationError) Key ¶
func (e InfocCurrentReplyValidationError) Key() bool
Key function returns key value.
func (InfocCurrentReplyValidationError) Reason ¶
func (e InfocCurrentReplyValidationError) Reason() string
Reason function returns reason value.
type InfocCurrentRequest ¶
type InfocCurrentRequest struct {
// contains filtered or unexported fields
}
func (*InfocCurrentRequest) Descriptor
deprecated
func (*InfocCurrentRequest) Descriptor() ([]byte, []int)
Deprecated: Use InfocCurrentRequest.ProtoReflect.Descriptor instead.
func (*InfocCurrentRequest) ProtoMessage ¶
func (*InfocCurrentRequest) ProtoMessage()
func (*InfocCurrentRequest) ProtoReflect ¶
func (x *InfocCurrentRequest) ProtoReflect() protoreflect.Message
func (*InfocCurrentRequest) Reset ¶
func (x *InfocCurrentRequest) Reset()
func (*InfocCurrentRequest) String ¶
func (x *InfocCurrentRequest) String() string
func (*InfocCurrentRequest) Validate ¶
func (m *InfocCurrentRequest) Validate() error
Validate checks the field values on InfocCurrentRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type InfocCurrentRequestValidationError ¶
type InfocCurrentRequestValidationError struct {
// contains filtered or unexported fields
}
InfocCurrentRequestValidationError is the validation error returned by InfocCurrentRequest.Validate if the designated constraints aren't met.
func (InfocCurrentRequestValidationError) Cause ¶
func (e InfocCurrentRequestValidationError) Cause() error
Cause function returns cause value.
func (InfocCurrentRequestValidationError) Error ¶
func (e InfocCurrentRequestValidationError) Error() string
Error satisfies the builtin error interface
func (InfocCurrentRequestValidationError) ErrorName ¶
func (e InfocCurrentRequestValidationError) ErrorName() string
ErrorName returns error name.
func (InfocCurrentRequestValidationError) Field ¶
func (e InfocCurrentRequestValidationError) Field() string
Field function returns field value.
func (InfocCurrentRequestValidationError) Key ¶
func (e InfocCurrentRequestValidationError) Key() bool
Key function returns key value.
func (InfocCurrentRequestValidationError) Reason ¶
func (e InfocCurrentRequestValidationError) Reason() string
Reason function returns reason value.
type InfocPostReply ¶
type InfocPostReply struct {
// contains filtered or unexported fields
}
func (*InfocPostReply) Descriptor
deprecated
func (*InfocPostReply) Descriptor() ([]byte, []int)
Deprecated: Use InfocPostReply.ProtoReflect.Descriptor instead.
func (*InfocPostReply) ProtoMessage ¶
func (*InfocPostReply) ProtoMessage()
func (*InfocPostReply) ProtoReflect ¶
func (x *InfocPostReply) ProtoReflect() protoreflect.Message
func (*InfocPostReply) Reset ¶
func (x *InfocPostReply) Reset()
func (*InfocPostReply) String ¶
func (x *InfocPostReply) String() string
func (*InfocPostReply) Validate ¶
func (m *InfocPostReply) Validate() error
Validate checks the field values on InfocPostReply with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type InfocPostReplyValidationError ¶
type InfocPostReplyValidationError struct {
// contains filtered or unexported fields
}
InfocPostReplyValidationError is the validation error returned by InfocPostReply.Validate if the designated constraints aren't met.
func (InfocPostReplyValidationError) Cause ¶
func (e InfocPostReplyValidationError) Cause() error
Cause function returns cause value.
func (InfocPostReplyValidationError) Error ¶
func (e InfocPostReplyValidationError) Error() string
Error satisfies the builtin error interface
func (InfocPostReplyValidationError) ErrorName ¶
func (e InfocPostReplyValidationError) ErrorName() string
ErrorName returns error name.
func (InfocPostReplyValidationError) Field ¶
func (e InfocPostReplyValidationError) Field() string
Field function returns field value.
func (InfocPostReplyValidationError) Key ¶
func (e InfocPostReplyValidationError) Key() bool
Key function returns key value.
func (InfocPostReplyValidationError) Reason ¶
func (e InfocPostReplyValidationError) Reason() string
Reason function returns reason value.
type InfocPostRequest ¶
type InfocPostRequest struct { Ics []*InfocConf `protobuf:"bytes,1,rep,name=ics,proto3" json:"ics,omitempty"` // contains filtered or unexported fields }
func (*InfocPostRequest) Descriptor
deprecated
func (*InfocPostRequest) Descriptor() ([]byte, []int)
Deprecated: Use InfocPostRequest.ProtoReflect.Descriptor instead.
func (*InfocPostRequest) GetIcs ¶
func (x *InfocPostRequest) GetIcs() []*InfocConf
func (*InfocPostRequest) ProtoMessage ¶
func (*InfocPostRequest) ProtoMessage()
func (*InfocPostRequest) ProtoReflect ¶
func (x *InfocPostRequest) ProtoReflect() protoreflect.Message
func (*InfocPostRequest) Reset ¶
func (x *InfocPostRequest) Reset()
func (*InfocPostRequest) String ¶
func (x *InfocPostRequest) String() string
func (*InfocPostRequest) Validate ¶
func (m *InfocPostRequest) Validate() error
Validate checks the field values on InfocPostRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type InfocPostRequestValidationError ¶
type InfocPostRequestValidationError struct {
// contains filtered or unexported fields
}
InfocPostRequestValidationError is the validation error returned by InfocPostRequest.Validate if the designated constraints aren't met.
func (InfocPostRequestValidationError) Cause ¶
func (e InfocPostRequestValidationError) Cause() error
Cause function returns cause value.
func (InfocPostRequestValidationError) Error ¶
func (e InfocPostRequestValidationError) Error() string
Error satisfies the builtin error interface
func (InfocPostRequestValidationError) ErrorName ¶
func (e InfocPostRequestValidationError) ErrorName() string
ErrorName returns error name.
func (InfocPostRequestValidationError) Field ¶
func (e InfocPostRequestValidationError) Field() string
Field function returns field value.
func (InfocPostRequestValidationError) Key ¶
func (e InfocPostRequestValidationError) Key() bool
Key function returns key value.
func (InfocPostRequestValidationError) Reason ¶
func (e InfocPostRequestValidationError) Reason() string
Reason function returns reason value.
type SyncPosReply ¶
type SyncPosReply struct {
// contains filtered or unexported fields
}
func (*SyncPosReply) Descriptor
deprecated
func (*SyncPosReply) Descriptor() ([]byte, []int)
Deprecated: Use SyncPosReply.ProtoReflect.Descriptor instead.
func (*SyncPosReply) ProtoMessage ¶
func (*SyncPosReply) ProtoMessage()
func (*SyncPosReply) ProtoReflect ¶
func (x *SyncPosReply) ProtoReflect() protoreflect.Message
func (*SyncPosReply) Reset ¶
func (x *SyncPosReply) Reset()
func (*SyncPosReply) String ¶
func (x *SyncPosReply) String() string
func (*SyncPosReply) Validate ¶
func (m *SyncPosReply) Validate() error
Validate checks the field values on SyncPosReply with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type SyncPosReplyValidationError ¶
type SyncPosReplyValidationError struct {
// contains filtered or unexported fields
}
SyncPosReplyValidationError is the validation error returned by SyncPosReply.Validate if the designated constraints aren't met.
func (SyncPosReplyValidationError) Cause ¶
func (e SyncPosReplyValidationError) Cause() error
Cause function returns cause value.
func (SyncPosReplyValidationError) Error ¶
func (e SyncPosReplyValidationError) Error() string
Error satisfies the builtin error interface
func (SyncPosReplyValidationError) ErrorName ¶
func (e SyncPosReplyValidationError) ErrorName() string
ErrorName returns error name.
func (SyncPosReplyValidationError) Field ¶
func (e SyncPosReplyValidationError) Field() string
Field function returns field value.
func (SyncPosReplyValidationError) Key ¶
func (e SyncPosReplyValidationError) Key() bool
Key function returns key value.
func (SyncPosReplyValidationError) Reason ¶
func (e SyncPosReplyValidationError) Reason() string
Reason function returns reason value.
type SyncPosRequest ¶
type SyncPosRequest struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` // contains filtered or unexported fields }
func (*SyncPosRequest) Descriptor
deprecated
func (*SyncPosRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncPosRequest.ProtoReflect.Descriptor instead.
func (*SyncPosRequest) GetAddr ¶
func (x *SyncPosRequest) GetAddr() string
func (*SyncPosRequest) ProtoMessage ¶
func (*SyncPosRequest) ProtoMessage()
func (*SyncPosRequest) ProtoReflect ¶
func (x *SyncPosRequest) ProtoReflect() protoreflect.Message
func (*SyncPosRequest) Reset ¶
func (x *SyncPosRequest) Reset()
func (*SyncPosRequest) String ¶
func (x *SyncPosRequest) String() string
func (*SyncPosRequest) Validate ¶
func (m *SyncPosRequest) Validate() error
Validate checks the field values on SyncPosRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type SyncPosRequestValidationError ¶
type SyncPosRequestValidationError struct {
// contains filtered or unexported fields
}
SyncPosRequestValidationError is the validation error returned by SyncPosRequest.Validate if the designated constraints aren't met.
func (SyncPosRequestValidationError) Cause ¶
func (e SyncPosRequestValidationError) Cause() error
Cause function returns cause value.
func (SyncPosRequestValidationError) Error ¶
func (e SyncPosRequestValidationError) Error() string
Error satisfies the builtin error interface
func (SyncPosRequestValidationError) ErrorName ¶
func (e SyncPosRequestValidationError) ErrorName() string
ErrorName returns error name.
func (SyncPosRequestValidationError) Field ¶
func (e SyncPosRequestValidationError) Field() string
Field function returns field value.
func (SyncPosRequestValidationError) Key ¶
func (e SyncPosRequestValidationError) Key() bool
Key function returns key value.
func (SyncPosRequestValidationError) Reason ¶
func (e SyncPosRequestValidationError) Reason() string
Reason function returns reason value.
type UnimplementedCanalServer ¶
type UnimplementedCanalServer struct { }
UnimplementedCanalServer must be embedded to have forward compatible implementations.
func (UnimplementedCanalServer) CheckMaster ¶
func (UnimplementedCanalServer) CheckMaster(context.Context, *CheckMasterRequest) (*CheckMasterReply, error)
func (UnimplementedCanalServer) Errors ¶
func (UnimplementedCanalServer) Errors(context.Context, *ErrorsRequest) (*ErrorsReply, error)
func (UnimplementedCanalServer) InfocCurrent ¶
func (UnimplementedCanalServer) InfocCurrent(context.Context, *InfocCurrentRequest) (*InfocCurrentReply, error)
func (UnimplementedCanalServer) InfocPost ¶
func (UnimplementedCanalServer) InfocPost(context.Context, *InfocPostRequest) (*InfocPostReply, error)
func (UnimplementedCanalServer) SyncPos ¶
func (UnimplementedCanalServer) SyncPos(context.Context, *SyncPosRequest) (*SyncPosReply, error)
type UnsafeCanalServer ¶
type UnsafeCanalServer interface {
// contains filtered or unexported methods
}
UnsafeCanalServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CanalServer will result in compilation errors.