Versions in this module Expand all Collapse all v1 v1.0.0 Oct 12, 2021 Changes in this version + func New(agentAddress string, opts ...clientOption) (*agentInstanceClient, error) + func RegisterAgentServer(s *grpc.Server, srv AgentServer) + func RegisterDeliveryServer(s *grpc.Server, srv DeliveryServer) + func WithClientId(clientId string) clientOption + func WithClientIp(clientIp string) clientOption + type AgentClient interface + GetElement func(ctx context.Context, in *GetElementReq, opts ...grpc.CallOption) (*GetElementResp, error) + Register func(ctx context.Context, in *RegisterReq, opts ...grpc.CallOption) (*EmptyResp, error) + Renew func(ctx context.Context, in *RegisterReq, opts ...grpc.CallOption) (*EmptyResp, error) + Unregister func(ctx context.Context, in *UnregisterReq, opts ...grpc.CallOption) (*EmptyResp, error) + Watch func(ctx context.Context, in *WatchReq, opts ...grpc.CallOption) (Agent_WatchClient, error) + func NewAgentClient(cc *grpc.ClientConn) AgentClient + type AgentServer interface + GetElement func(context.Context, *GetElementReq) (*GetElementResp, error) + Register func(context.Context, *RegisterReq) (*EmptyResp, error) + Renew func(context.Context, *RegisterReq) (*EmptyResp, error) + Unregister func(context.Context, *UnregisterReq) (*EmptyResp, error) + Watch func(*WatchReq, Agent_WatchServer) error + type Agent_WatchClient interface + Recv func() (*WatchResp, error) + type Agent_WatchServer interface + Send func(*WatchResp) error + type DeliveryClient interface + Dispatch func(ctx context.Context, in *DispatchReq, opts ...grpc.CallOption) (*DispatchResp, error) + func DialDelivery(addr string) (DeliveryClient, error) + func NewDeliveryClient(cc *grpc.ClientConn) DeliveryClient + type DeliveryServer interface + Dispatch func(context.Context, *DispatchReq) (*DispatchResp, error) + type DispatchReq struct + Elems []*concept.Element + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DispatchReq) Descriptor() ([]byte, []int) + func (*DispatchReq) ProtoMessage() + func (m *DispatchReq) GetElems() []*concept.Element + func (m *DispatchReq) Reset() + func (m *DispatchReq) String() string + func (m *DispatchReq) Validate() error + func (m *DispatchReq) XXX_DiscardUnknown() + func (m *DispatchReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DispatchReq) XXX_Merge(src proto.Message) + func (m *DispatchReq) XXX_Size() int + func (m *DispatchReq) XXX_Unmarshal(b []byte) error + type DispatchReqValidationError struct + func (e DispatchReqValidationError) Cause() error + func (e DispatchReqValidationError) Error() string + func (e DispatchReqValidationError) ErrorName() string + func (e DispatchReqValidationError) Field() string + func (e DispatchReqValidationError) Key() bool + func (e DispatchReqValidationError) Reason() string + type DispatchResp struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DispatchResp) Descriptor() ([]byte, []int) + func (*DispatchResp) ProtoMessage() + func (m *DispatchResp) Reset() + func (m *DispatchResp) String() string + func (m *DispatchResp) Validate() error + func (m *DispatchResp) XXX_DiscardUnknown() + func (m *DispatchResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DispatchResp) XXX_Merge(src proto.Message) + func (m *DispatchResp) XXX_Size() int + func (m *DispatchResp) XXX_Unmarshal(b []byte) error + type DispatchRespValidationError struct + func (e DispatchRespValidationError) Cause() error + func (e DispatchRespValidationError) Error() string + func (e DispatchRespValidationError) ErrorName() string + func (e DispatchRespValidationError) Field() string + func (e DispatchRespValidationError) Key() bool + func (e DispatchRespValidationError) Reason() string + type EmptyResp struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EmptyResp) Descriptor() ([]byte, []int) + func (*EmptyResp) ProtoMessage() + func (m *EmptyResp) Reset() + func (m *EmptyResp) String() string + func (m *EmptyResp) Validate() error + func (m *EmptyResp) XXX_DiscardUnknown() + func (m *EmptyResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EmptyResp) XXX_Merge(src proto.Message) + func (m *EmptyResp) XXX_Size() int + func (m *EmptyResp) XXX_Unmarshal(b []byte) error + type EmptyRespValidationError struct + func (e EmptyRespValidationError) Cause() error + func (e EmptyRespValidationError) Error() string + func (e EmptyRespValidationError) ErrorName() string + func (e EmptyRespValidationError) Field() string + func (e EmptyRespValidationError) Key() bool + func (e EmptyRespValidationError) Reason() string + type GetElementReq struct + App string + Env string + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetElementReq) Descriptor() ([]byte, []int) + func (*GetElementReq) ProtoMessage() + func (m *GetElementReq) GetApp() string + func (m *GetElementReq) GetEnv() string + func (m *GetElementReq) GetKeys() []string + func (m *GetElementReq) Reset() + func (m *GetElementReq) String() string + func (m *GetElementReq) Validate() error + func (m *GetElementReq) XXX_DiscardUnknown() + func (m *GetElementReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetElementReq) XXX_Merge(src proto.Message) + func (m *GetElementReq) XXX_Size() int + func (m *GetElementReq) XXX_Unmarshal(b []byte) error + type GetElementReqValidationError struct + func (e GetElementReqValidationError) Cause() error + func (e GetElementReqValidationError) Error() string + func (e GetElementReqValidationError) ErrorName() string + func (e GetElementReqValidationError) Field() string + func (e GetElementReqValidationError) Key() bool + func (e GetElementReqValidationError) Reason() string + type GetElementResp struct + Elems []*concept.Element + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetElementResp) Descriptor() ([]byte, []int) + func (*GetElementResp) ProtoMessage() + func (m *GetElementResp) GetElems() []*concept.Element + func (m *GetElementResp) Reset() + func (m *GetElementResp) String() string + func (m *GetElementResp) Validate() error + func (m *GetElementResp) XXX_DiscardUnknown() + func (m *GetElementResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetElementResp) XXX_Merge(src proto.Message) + func (m *GetElementResp) XXX_Size() int + func (m *GetElementResp) XXX_Unmarshal(b []byte) error + type GetElementRespValidationError struct + func (e GetElementRespValidationError) Cause() error + func (e GetElementRespValidationError) Error() string + func (e GetElementRespValidationError) ErrorName() string + func (e GetElementRespValidationError) Field() string + func (e GetElementRespValidationError) Key() bool + func (e GetElementRespValidationError) Reason() string + type RegisterReq struct + ClientId string + ClientIp string + Watching []*concept.Instance_Watching + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegisterReq) Descriptor() ([]byte, []int) + func (*RegisterReq) ProtoMessage() + func (m *RegisterReq) GetClientId() string + func (m *RegisterReq) GetClientIp() string + func (m *RegisterReq) GetWatching() []*concept.Instance_Watching + func (m *RegisterReq) Reset() + func (m *RegisterReq) String() string + func (m *RegisterReq) Validate() error + func (m *RegisterReq) XXX_DiscardUnknown() + func (m *RegisterReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegisterReq) XXX_Merge(src proto.Message) + func (m *RegisterReq) XXX_Size() int + func (m *RegisterReq) XXX_Unmarshal(b []byte) error + type RegisterReqValidationError struct + func (e RegisterReqValidationError) Cause() error + func (e RegisterReqValidationError) Error() string + func (e RegisterReqValidationError) ErrorName() string + func (e RegisterReqValidationError) Field() string + func (e RegisterReqValidationError) Key() bool + func (e RegisterReqValidationError) Reason() string + type UnimplementedAgentServer struct + func (*UnimplementedAgentServer) GetElement(ctx context.Context, req *GetElementReq) (*GetElementResp, error) + func (*UnimplementedAgentServer) Register(ctx context.Context, req *RegisterReq) (*EmptyResp, error) + func (*UnimplementedAgentServer) Renew(ctx context.Context, req *RegisterReq) (*EmptyResp, error) + func (*UnimplementedAgentServer) Unregister(ctx context.Context, req *UnregisterReq) (*EmptyResp, error) + func (*UnimplementedAgentServer) Watch(req *WatchReq, srv Agent_WatchServer) error + type UnimplementedDeliveryServer struct + func (*UnimplementedDeliveryServer) Dispatch(ctx context.Context, req *DispatchReq) (*DispatchResp, error) + type UnregisterReq struct + ClientId string + ClientIp string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UnregisterReq) Descriptor() ([]byte, []int) + func (*UnregisterReq) ProtoMessage() + func (m *UnregisterReq) GetClientId() string + func (m *UnregisterReq) GetClientIp() string + func (m *UnregisterReq) Reset() + func (m *UnregisterReq) String() string + func (m *UnregisterReq) Validate() error + func (m *UnregisterReq) XXX_DiscardUnknown() + func (m *UnregisterReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UnregisterReq) XXX_Merge(src proto.Message) + func (m *UnregisterReq) XXX_Size() int + func (m *UnregisterReq) XXX_Unmarshal(b []byte) error + type UnregisterReqValidationError struct + func (e UnregisterReqValidationError) Cause() error + func (e UnregisterReqValidationError) Error() string + func (e UnregisterReqValidationError) ErrorName() string + func (e UnregisterReqValidationError) Field() string + func (e UnregisterReqValidationError) Key() bool + func (e UnregisterReqValidationError) Reason() string + type WatchHandlerFunc func(next *concept.Element) + type WatchReq struct + ClientId string + ClientIp string + Watching []*concept.Instance_Watching + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchReq) Descriptor() ([]byte, []int) + func (*WatchReq) ProtoMessage() + func (m *WatchReq) GetClientId() string + func (m *WatchReq) GetClientIp() string + func (m *WatchReq) GetWatching() []*concept.Instance_Watching + func (m *WatchReq) Reset() + func (m *WatchReq) String() string + func (m *WatchReq) Validate() error + func (m *WatchReq) XXX_DiscardUnknown() + func (m *WatchReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchReq) XXX_Merge(src proto.Message) + func (m *WatchReq) XXX_Size() int + func (m *WatchReq) XXX_Unmarshal(b []byte) error + type WatchReqValidationError struct + func (e WatchReqValidationError) Cause() error + func (e WatchReqValidationError) Error() string + func (e WatchReqValidationError) ErrorName() string + func (e WatchReqValidationError) Field() string + func (e WatchReqValidationError) Key() bool + func (e WatchReqValidationError) Reason() string + type WatchResp struct + Elem *concept.Element + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchResp) Descriptor() ([]byte, []int) + func (*WatchResp) ProtoMessage() + func (m *WatchResp) GetElem() *concept.Element + func (m *WatchResp) Reset() + func (m *WatchResp) String() string + func (m *WatchResp) Validate() error + func (m *WatchResp) XXX_DiscardUnknown() + func (m *WatchResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchResp) XXX_Merge(src proto.Message) + func (m *WatchResp) XXX_Size() int + func (m *WatchResp) XXX_Unmarshal(b []byte) error + type WatchRespValidationError struct + func (e WatchRespValidationError) Cause() error + func (e WatchRespValidationError) Error() string + func (e WatchRespValidationError) ErrorName() string + func (e WatchRespValidationError) Field() string + func (e WatchRespValidationError) Key() bool + func (e WatchRespValidationError) Reason() string
Go to main page