agent

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2021 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New 

func New(agentAddress string, opts ...clientOption) (*agentInstanceClient, error)

func RegisterAgentServer 

func RegisterAgentServer(s *grpc.Server, srv AgentServer)

func RegisterDeliveryServer 

func RegisterDeliveryServer(s *grpc.Server, srv DeliveryServer)

func WithClientId 

func WithClientId(clientId string) clientOption

func WithClientIp 

func WithClientIp(clientIp string) clientOption

Types

type AgentClient 

type AgentClient interface {
	GetElement(ctx context.Context, in *GetElementReq, opts ...grpc.CallOption) (*GetElementResp, error)
	Unregister(ctx context.Context, in *UnregisterReq, opts ...grpc.CallOption) (*EmptyResp, error)
	Register(ctx context.Context, in *RegisterReq, opts ...grpc.CallOption) (*EmptyResp, error)
	Renew(ctx context.Context, in *RegisterReq, opts ...grpc.CallOption) (*EmptyResp, error)
	Watch(ctx context.Context, in *WatchReq, opts ...grpc.CallOption) (Agent_WatchClient, error)
}

AgentClient is the client API for Agent service.

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

func NewAgentClient 

func NewAgentClient(cc *grpc.ClientConn) AgentClient

type AgentServer 

type AgentServer interface {
	GetElement(context.Context, *GetElementReq) (*GetElementResp, error)
	Unregister(context.Context, *UnregisterReq) (*EmptyResp, error)
	Register(context.Context, *RegisterReq) (*EmptyResp, error)
	Renew(context.Context, *RegisterReq) (*EmptyResp, error)
	Watch(*WatchReq, Agent_WatchServer) error
}

AgentServer is the server API for Agent service.

type Agent_WatchClient 

type Agent_WatchClient interface {
	Recv() (*WatchResp, error)
	grpc.ClientStream
}

type Agent_WatchServer 

type Agent_WatchServer interface {
	Send(*WatchResp) error
	grpc.ServerStream
}

type DeliveryClient 

type DeliveryClient interface {
	Dispatch(ctx context.Context, in *DispatchReq, opts ...grpc.CallOption) (*DispatchResp, error)
}

DeliveryClient is the client API for Delivery service.

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

func DialDelivery 

func DialDelivery(addr string) (DeliveryClient, error)

func NewDeliveryClient 

func NewDeliveryClient(cc *grpc.ClientConn) DeliveryClient

type DeliveryServer 

type DeliveryServer interface {
	Dispatch(context.Context, *DispatchReq) (*DispatchResp, error)
}

DeliveryServer is the server API for Delivery service.

type DispatchReq 

type DispatchReq struct {
	Elems                []*concept.Element `protobuf:"bytes,1,rep,name=elems,proto3" json:"elems,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DispatchReq) Descriptor 

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

func (*DispatchReq) GetElems 

func (m *DispatchReq) GetElems() []*concept.Element

func (*DispatchReq) ProtoMessage 

func (*DispatchReq) ProtoMessage()

func (*DispatchReq) Reset 

func (m *DispatchReq) Reset()

func (*DispatchReq) String 

func (m *DispatchReq) String() string

func (*DispatchReq) Validate 

func (m *DispatchReq) Validate() error

Validate checks the field values on DispatchReq with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DispatchReq) XXX_DiscardUnknown 

func (m *DispatchReq) XXX_DiscardUnknown()

func (*DispatchReq) XXX_Marshal 

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

func (*DispatchReq) XXX_Merge 

func (m *DispatchReq) XXX_Merge(src proto.Message)

func (*DispatchReq) XXX_Size 

func (m *DispatchReq) XXX_Size() int

func (*DispatchReq) XXX_Unmarshal 

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

type DispatchReqValidationError 

type DispatchReqValidationError struct {
	// contains filtered or unexported fields
}

DispatchReqValidationError is the validation error returned by DispatchReq.Validate if the designated constraints aren't met.

func (DispatchReqValidationError) Cause 

func (e DispatchReqValidationError) Cause() error

Cause function returns cause value.

func (DispatchReqValidationError) Error 

func (e DispatchReqValidationError) Error() string

Error satisfies the builtin error interface

func (DispatchReqValidationError) ErrorName 

func (e DispatchReqValidationError) ErrorName() string

ErrorName returns error name.

func (DispatchReqValidationError) Field 

func (e DispatchReqValidationError) Field() string

Field function returns field value.

func (DispatchReqValidationError) Key 

func (e DispatchReqValidationError) Key() bool

Key function returns key value.

func (DispatchReqValidationError) Reason 

func (e DispatchReqValidationError) Reason() string

Reason function returns reason value.

type DispatchResp 

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

func (*DispatchResp) Descriptor 

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

func (*DispatchResp) ProtoMessage 

func (*DispatchResp) ProtoMessage()

func (*DispatchResp) Reset 

func (m *DispatchResp) Reset()

func (*DispatchResp) String 

func (m *DispatchResp) String() string

func (*DispatchResp) Validate 

func (m *DispatchResp) Validate() error

Validate checks the field values on DispatchResp with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DispatchResp) XXX_DiscardUnknown 

func (m *DispatchResp) XXX_DiscardUnknown()

func (*DispatchResp) XXX_Marshal 

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

func (*DispatchResp) XXX_Merge 

func (m *DispatchResp) XXX_Merge(src proto.Message)

func (*DispatchResp) XXX_Size 

func (m *DispatchResp) XXX_Size() int

func (*DispatchResp) XXX_Unmarshal 

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

type DispatchRespValidationError 

type DispatchRespValidationError struct {
	// contains filtered or unexported fields
}

DispatchRespValidationError is the validation error returned by DispatchResp.Validate if the designated constraints aren't met.

func (DispatchRespValidationError) Cause 

func (e DispatchRespValidationError) Cause() error

Cause function returns cause value.

func (DispatchRespValidationError) Error 

func (e DispatchRespValidationError) Error() string

Error satisfies the builtin error interface

func (DispatchRespValidationError) ErrorName 

func (e DispatchRespValidationError) ErrorName() string

ErrorName returns error name.

func (DispatchRespValidationError) Field 

func (e DispatchRespValidationError) Field() string

Field function returns field value.

func (DispatchRespValidationError) Key 

func (e DispatchRespValidationError) Key() bool

Key function returns key value.

func (DispatchRespValidationError) Reason 

func (e DispatchRespValidationError) Reason() string

Reason function returns reason value.

type EmptyResp 

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

func (*EmptyResp) Descriptor 

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

func (*EmptyResp) ProtoMessage 

func (*EmptyResp) ProtoMessage()

func (*EmptyResp) Reset 

func (m *EmptyResp) Reset()

func (*EmptyResp) String 

func (m *EmptyResp) String() string

func (*EmptyResp) Validate 

func (m *EmptyResp) Validate() error

Validate checks the field values on EmptyResp with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*EmptyResp) XXX_DiscardUnknown 

func (m *EmptyResp) XXX_DiscardUnknown()

func (*EmptyResp) XXX_Marshal 

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

func (*EmptyResp) XXX_Merge 

func (m *EmptyResp) XXX_Merge(src proto.Message)

func (*EmptyResp) XXX_Size 

func (m *EmptyResp) XXX_Size() int

func (*EmptyResp) XXX_Unmarshal 

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

type EmptyRespValidationError 

type EmptyRespValidationError struct {
	// contains filtered or unexported fields
}

EmptyRespValidationError is the validation error returned by EmptyResp.Validate if the designated constraints aren't met.

func (EmptyRespValidationError) Cause 

func (e EmptyRespValidationError) Cause() error

Cause function returns cause value.

func (EmptyRespValidationError) Error 

func (e EmptyRespValidationError) Error() string

Error satisfies the builtin error interface

func (EmptyRespValidationError) ErrorName 

func (e EmptyRespValidationError) ErrorName() string

ErrorName returns error name.

func (EmptyRespValidationError) Field 

func (e EmptyRespValidationError) Field() string

Field function returns field value.

func (EmptyRespValidationError) Key 

func (e EmptyRespValidationError) Key() bool

Key function returns key value.

func (EmptyRespValidationError) Reason 

func (e EmptyRespValidationError) Reason() string

Reason function returns reason value.

type GetElementReq 

type GetElementReq struct {
	App                  string   `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	Env                  string   `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	Keys                 []string `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetElementReq) Descriptor 

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

func (*GetElementReq) GetApp 

func (m *GetElementReq) GetApp() string

func (*GetElementReq) GetEnv 

func (m *GetElementReq) GetEnv() string

func (*GetElementReq) GetKeys 

func (m *GetElementReq) GetKeys() []string

func (*GetElementReq) ProtoMessage 

func (*GetElementReq) ProtoMessage()

func (*GetElementReq) Reset 

func (m *GetElementReq) Reset()

func (*GetElementReq) String 

func (m *GetElementReq) String() string

func (*GetElementReq) Validate 

func (m *GetElementReq) Validate() error

Validate checks the field values on GetElementReq with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*GetElementReq) XXX_DiscardUnknown 

func (m *GetElementReq) XXX_DiscardUnknown()

func (*GetElementReq) XXX_Marshal 

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

func (*GetElementReq) XXX_Merge 

func (m *GetElementReq) XXX_Merge(src proto.Message)

func (*GetElementReq) XXX_Size 

func (m *GetElementReq) XXX_Size() int

func (*GetElementReq) XXX_Unmarshal 

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

type GetElementReqValidationError 

type GetElementReqValidationError struct {
	// contains filtered or unexported fields
}

GetElementReqValidationError is the validation error returned by GetElementReq.Validate if the designated constraints aren't met.

func (GetElementReqValidationError) Cause 

func (e GetElementReqValidationError) Cause() error

Cause function returns cause value.

func (GetElementReqValidationError) Error 

func (e GetElementReqValidationError) Error() string

Error satisfies the builtin error interface

func (GetElementReqValidationError) ErrorName 

func (e GetElementReqValidationError) ErrorName() string

ErrorName returns error name.

func (GetElementReqValidationError) Field 

func (e GetElementReqValidationError) Field() string

Field function returns field value.

func (GetElementReqValidationError) Key 

func (e GetElementReqValidationError) Key() bool

Key function returns key value.

func (GetElementReqValidationError) Reason 

func (e GetElementReqValidationError) Reason() string

Reason function returns reason value.

type GetElementResp 

type GetElementResp struct {
	Elems                []*concept.Element `protobuf:"bytes,1,rep,name=elems,proto3" json:"elems,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetElementResp) Descriptor 

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

func (*GetElementResp) GetElems 

func (m *GetElementResp) GetElems() []*concept.Element

func (*GetElementResp) ProtoMessage 

func (*GetElementResp) ProtoMessage()

func (*GetElementResp) Reset 

func (m *GetElementResp) Reset()

func (*GetElementResp) String 

func (m *GetElementResp) String() string

func (*GetElementResp) Validate 

func (m *GetElementResp) Validate() error

Validate checks the field values on GetElementResp with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*GetElementResp) XXX_DiscardUnknown 

func (m *GetElementResp) XXX_DiscardUnknown()

func (*GetElementResp) XXX_Marshal 

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

func (*GetElementResp) XXX_Merge 

func (m *GetElementResp) XXX_Merge(src proto.Message)

func (*GetElementResp) XXX_Size 

func (m *GetElementResp) XXX_Size() int

func (*GetElementResp) XXX_Unmarshal 

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

type GetElementRespValidationError 

type GetElementRespValidationError struct {
	// contains filtered or unexported fields
}

GetElementRespValidationError is the validation error returned by GetElementResp.Validate if the designated constraints aren't met.

func (GetElementRespValidationError) Cause 

func (e GetElementRespValidationError) Cause() error

Cause function returns cause value.

func (GetElementRespValidationError) Error 

func (e GetElementRespValidationError) Error() string

Error satisfies the builtin error interface

func (GetElementRespValidationError) ErrorName 

func (e GetElementRespValidationError) ErrorName() string

ErrorName returns error name.

func (GetElementRespValidationError) Field 

func (e GetElementRespValidationError) Field() string

Field function returns field value.

func (GetElementRespValidationError) Key 

func (e GetElementRespValidationError) Key() bool

Key function returns key value.

func (GetElementRespValidationError) Reason 

func (e GetElementRespValidationError) Reason() string

Reason function returns reason value.

type RegisterReq 

type RegisterReq struct {
	ClientId             string                       `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientIp             string                       `protobuf:"bytes,2,opt,name=clientIp,proto3" json:"clientIp,omitempty"`
	Watching             []*concept.Instance_Watching `protobuf:"bytes,3,rep,name=watching,proto3" json:"watching,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*RegisterReq) Descriptor 

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

func (*RegisterReq) GetClientId 

func (m *RegisterReq) GetClientId() string

func (*RegisterReq) GetClientIp 

func (m *RegisterReq) GetClientIp() string

func (*RegisterReq) GetWatching 

func (m *RegisterReq) GetWatching() []*concept.Instance_Watching

func (*RegisterReq) ProtoMessage 

func (*RegisterReq) ProtoMessage()

func (*RegisterReq) Reset 

func (m *RegisterReq) Reset()

func (*RegisterReq) String 

func (m *RegisterReq) String() string

func (*RegisterReq) Validate 

func (m *RegisterReq) Validate() error

Validate checks the field values on RegisterReq with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*RegisterReq) XXX_DiscardUnknown 

func (m *RegisterReq) XXX_DiscardUnknown()

func (*RegisterReq) XXX_Marshal 

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

func (*RegisterReq) XXX_Merge 

func (m *RegisterReq) XXX_Merge(src proto.Message)

func (*RegisterReq) XXX_Size 

func (m *RegisterReq) XXX_Size() int

func (*RegisterReq) XXX_Unmarshal 

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

type RegisterReqValidationError 

type RegisterReqValidationError struct {
	// contains filtered or unexported fields
}

RegisterReqValidationError is the validation error returned by RegisterReq.Validate if the designated constraints aren't met.

func (RegisterReqValidationError) Cause 

func (e RegisterReqValidationError) Cause() error

Cause function returns cause value.

func (RegisterReqValidationError) Error 

func (e RegisterReqValidationError) Error() string

Error satisfies the builtin error interface

func (RegisterReqValidationError) ErrorName 

func (e RegisterReqValidationError) ErrorName() string

ErrorName returns error name.

func (RegisterReqValidationError) Field 

func (e RegisterReqValidationError) Field() string

Field function returns field value.

func (RegisterReqValidationError) Key 

func (e RegisterReqValidationError) Key() bool

Key function returns key value.

func (RegisterReqValidationError) Reason 

func (e RegisterReqValidationError) Reason() string

Reason function returns reason value.

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) GetElement 

func (*UnimplementedAgentServer) GetElement(ctx context.Context, req *GetElementReq) (*GetElementResp, error)

func (*UnimplementedAgentServer) Register 

func (*UnimplementedAgentServer) Register(ctx context.Context, req *RegisterReq) (*EmptyResp, error)

func (*UnimplementedAgentServer) Renew 

func (*UnimplementedAgentServer) Renew(ctx context.Context, req *RegisterReq) (*EmptyResp, error)

func (*UnimplementedAgentServer) Unregister 

func (*UnimplementedAgentServer) Unregister(ctx context.Context, req *UnregisterReq) (*EmptyResp, error)

func (*UnimplementedAgentServer) Watch 

func (*UnimplementedAgentServer) Watch(req *WatchReq, srv Agent_WatchServer) error

type UnimplementedDeliveryServer 

type UnimplementedDeliveryServer struct {
}

UnimplementedDeliveryServer can be embedded to have forward compatible implementations.

func (*UnimplementedDeliveryServer) Dispatch 

func (*UnimplementedDeliveryServer) Dispatch(ctx context.Context, req *DispatchReq) (*DispatchResp, error)

type UnregisterReq 

type UnregisterReq struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientIp             string   `protobuf:"bytes,2,opt,name=clientIp,proto3" json:"clientIp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterReq) Descriptor 

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

func (*UnregisterReq) GetClientId 

func (m *UnregisterReq) GetClientId() string

func (*UnregisterReq) GetClientIp 

func (m *UnregisterReq) GetClientIp() string

func (*UnregisterReq) ProtoMessage 

func (*UnregisterReq) ProtoMessage()

func (*UnregisterReq) Reset 

func (m *UnregisterReq) Reset()

func (*UnregisterReq) String 

func (m *UnregisterReq) String() string

func (*UnregisterReq) Validate 

func (m *UnregisterReq) Validate() error

Validate checks the field values on UnregisterReq with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*UnregisterReq) XXX_DiscardUnknown 

func (m *UnregisterReq) XXX_DiscardUnknown()

func (*UnregisterReq) XXX_Marshal 

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

func (*UnregisterReq) XXX_Merge 

func (m *UnregisterReq) XXX_Merge(src proto.Message)

func (*UnregisterReq) XXX_Size 

func (m *UnregisterReq) XXX_Size() int

func (*UnregisterReq) XXX_Unmarshal 

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

type UnregisterReqValidationError 

type UnregisterReqValidationError struct {
	// contains filtered or unexported fields
}

UnregisterReqValidationError is the validation error returned by UnregisterReq.Validate if the designated constraints aren't met.

func (UnregisterReqValidationError) Cause 

func (e UnregisterReqValidationError) Cause() error

Cause function returns cause value.

func (UnregisterReqValidationError) Error 

func (e UnregisterReqValidationError) Error() string

Error satisfies the builtin error interface

func (UnregisterReqValidationError) ErrorName 

func (e UnregisterReqValidationError) ErrorName() string

ErrorName returns error name.

func (UnregisterReqValidationError) Field 

func (e UnregisterReqValidationError) Field() string

Field function returns field value.

func (UnregisterReqValidationError) Key 

func (e UnregisterReqValidationError) Key() bool

Key function returns key value.

func (UnregisterReqValidationError) Reason 

func (e UnregisterReqValidationError) Reason() string

Reason function returns reason value.

type WatchHandlerFunc 

type WatchHandlerFunc func(next *concept.Element)

type WatchReq 

type WatchReq struct {
	Watching []*concept.Instance_Watching `protobuf:"bytes,1,rep,name=watching,proto3" json:"watching,omitempty"`
	//  string app = 1 [(validate.rules).string = {min_len: 3, max_len: 30}];
	//  string env = 2 [(validate.rules).string = {min_len: 3, max_len: 30}];
	//  repeated string watchingKeys = 3 [(validate.rules).repeated = {unique: true, min_items: 1, max_items: 100}];
	ClientId             string   `protobuf:"bytes,4,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientIp             string   `protobuf:"bytes,5,opt,name=clientIp,proto3" json:"clientIp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchReq) Descriptor 

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

func (*WatchReq) GetClientId 

func (m *WatchReq) GetClientId() string

func (*WatchReq) GetClientIp 

func (m *WatchReq) GetClientIp() string

func (*WatchReq) GetWatching 

func (m *WatchReq) GetWatching() []*concept.Instance_Watching

func (*WatchReq) ProtoMessage 

func (*WatchReq) ProtoMessage()

func (*WatchReq) Reset 

func (m *WatchReq) Reset()

func (*WatchReq) String 

func (m *WatchReq) String() string

func (*WatchReq) Validate 

func (m *WatchReq) Validate() error

Validate checks the field values on WatchReq with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WatchReq) XXX_DiscardUnknown 

func (m *WatchReq) XXX_DiscardUnknown()

func (*WatchReq) XXX_Marshal 

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

func (*WatchReq) XXX_Merge 

func (m *WatchReq) XXX_Merge(src proto.Message)

func (*WatchReq) XXX_Size 

func (m *WatchReq) XXX_Size() int

func (*WatchReq) XXX_Unmarshal 

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

type WatchReqValidationError 

type WatchReqValidationError struct {
	// contains filtered or unexported fields
}

WatchReqValidationError is the validation error returned by WatchReq.Validate if the designated constraints aren't met.

func (WatchReqValidationError) Cause 

func (e WatchReqValidationError) Cause() error

Cause function returns cause value.

func (WatchReqValidationError) Error 

func (e WatchReqValidationError) Error() string

Error satisfies the builtin error interface

func (WatchReqValidationError) ErrorName 

func (e WatchReqValidationError) ErrorName() string

ErrorName returns error name.

func (WatchReqValidationError) Field 

func (e WatchReqValidationError) Field() string

Field function returns field value.

func (WatchReqValidationError) Key 

func (e WatchReqValidationError) Key() bool

Key function returns key value.

func (WatchReqValidationError) Reason 

func (e WatchReqValidationError) Reason() string

Reason function returns reason value.

type WatchResp 

type WatchResp struct {
	Elem                 *concept.Element `protobuf:"bytes,1,opt,name=elem,proto3" json:"elem,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*WatchResp) Descriptor 

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

func (*WatchResp) GetElem 

func (m *WatchResp) GetElem() *concept.Element

func (*WatchResp) ProtoMessage 

func (*WatchResp) ProtoMessage()

func (*WatchResp) Reset 

func (m *WatchResp) Reset()

func (*WatchResp) String 

func (m *WatchResp) String() string

func (*WatchResp) Validate 

func (m *WatchResp) Validate() error

Validate checks the field values on WatchResp with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WatchResp) XXX_DiscardUnknown 

func (m *WatchResp) XXX_DiscardUnknown()

func (*WatchResp) XXX_Marshal 

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

func (*WatchResp) XXX_Merge 

func (m *WatchResp) XXX_Merge(src proto.Message)

func (*WatchResp) XXX_Size 

func (m *WatchResp) XXX_Size() int

func (*WatchResp) XXX_Unmarshal 

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

type WatchRespValidationError 

type WatchRespValidationError struct {
	// contains filtered or unexported fields
}

WatchRespValidationError is the validation error returned by WatchResp.Validate if the designated constraints aren't met.

func (WatchRespValidationError) Cause 

func (e WatchRespValidationError) Cause() error

Cause function returns cause value.

func (WatchRespValidationError) Error 

func (e WatchRespValidationError) Error() string

Error satisfies the builtin error interface

func (WatchRespValidationError) ErrorName 

func (e WatchRespValidationError) ErrorName() string

ErrorName returns error name.

func (WatchRespValidationError) Field 

func (e WatchRespValidationError) Field() string

Field function returns field value.

func (WatchRespValidationError) Key 

func (e WatchRespValidationError) Key() bool

Key function returns key value.

func (WatchRespValidationError) Reason 

func (e WatchRespValidationError) Reason() string

Reason function returns reason value.

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.