Documentation ¶
Index ¶
- Variables
- func RegisterEntityHTTPServer(container *go_restful.Container, srv EntityHTTPServer)
- func RegisterEntityServer(s grpc.ServiceRegistrar, srv EntityServer)
- func RegisterProbeHTTPServer(container *go_restful.Container, srv ProbeHTTPServer)
- func RegisterProbeServer(s grpc.ServiceRegistrar, srv ProbeServer)
- func RegisterProxyHTTPServer(container *go_restful.Container, srv ProxyHTTPServer)
- func RegisterProxyServer(s grpc.ServiceRegistrar, srv ProxyServer)
- func RegisterSearchHTTPServer(container *go_restful.Container, srv SearchHTTPServer)
- func RegisterSearchServer(s grpc.ServiceRegistrar, srv SearchServer)
- func RegisterSubscriptionHTTPServer(container *go_restful.Container, srv SubscriptionHTTPServer)
- func RegisterSubscriptionServer(s grpc.ServiceRegistrar, srv SubscriptionServer)
- func RegisterTSHTTPServer(container *go_restful.Container, srv TSHTTPServer)
- func RegisterTSServer(s grpc.ServiceRegistrar, srv TSServer)
- func RegisterTopicHTTPServer(container *go_restful.Container, srv TopicHTTPServer)
- func RegisterTopicServer(s grpc.ServiceRegistrar, srv TopicServer)
- type AppendMapperRequest
- func (*AppendMapperRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppendMapperRequest) GetEntityId() string
- func (x *AppendMapperRequest) GetMapper() *Mapper
- func (x *AppendMapperRequest) GetOwner() string
- func (x *AppendMapperRequest) GetSource() string
- func (x *AppendMapperRequest) GetType() string
- func (*AppendMapperRequest) ProtoMessage()
- func (x *AppendMapperRequest) ProtoReflect() protoreflect.Message
- func (x *AppendMapperRequest) Reset()
- func (x *AppendMapperRequest) String() string
- type AppendMapperResponse
- func (*AppendMapperResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AppendMapperResponse) GetEntityId() string
- func (x *AppendMapperResponse) GetMapper() *Mapper
- func (x *AppendMapperResponse) GetOwner() string
- func (x *AppendMapperResponse) GetSource() string
- func (x *AppendMapperResponse) GetType() string
- func (*AppendMapperResponse) ProtoMessage()
- func (x *AppendMapperResponse) ProtoReflect() protoreflect.Message
- func (x *AppendMapperResponse) Reset()
- func (x *AppendMapperResponse) String() string
- type CreateEntityRequest
- func (*CreateEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateEntityRequest) GetFrom() string
- func (x *CreateEntityRequest) GetId() string
- func (x *CreateEntityRequest) GetOwner() string
- func (x *CreateEntityRequest) GetProperties() *_struct.Value
- func (x *CreateEntityRequest) GetSource() string
- func (x *CreateEntityRequest) GetType() string
- func (*CreateEntityRequest) ProtoMessage()
- func (x *CreateEntityRequest) ProtoReflect() protoreflect.Message
- func (x *CreateEntityRequest) Reset()
- func (x *CreateEntityRequest) String() string
- type CreateSubscriptionRequest
- func (*CreateSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSubscriptionRequest) GetId() string
- func (x *CreateSubscriptionRequest) GetOwner() string
- func (x *CreateSubscriptionRequest) GetSource() string
- func (x *CreateSubscriptionRequest) GetSubscription() *SubscriptionObject
- func (*CreateSubscriptionRequest) ProtoMessage()
- func (x *CreateSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSubscriptionRequest) Reset()
- func (x *CreateSubscriptionRequest) String() string
- type DeleteByIDRequest
- func (*DeleteByIDRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteByIDRequest) GetId() string
- func (x *DeleteByIDRequest) GetOwner() string
- func (x *DeleteByIDRequest) GetSource() string
- func (*DeleteByIDRequest) ProtoMessage()
- func (x *DeleteByIDRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteByIDRequest) Reset()
- func (x *DeleteByIDRequest) String() string
- type DeleteByIDResponse
- type DeleteEntityRequest
- func (*DeleteEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteEntityRequest) GetId() string
- func (x *DeleteEntityRequest) GetOwner() string
- func (x *DeleteEntityRequest) GetSource() string
- func (x *DeleteEntityRequest) GetType() string
- func (*DeleteEntityRequest) ProtoMessage()
- func (x *DeleteEntityRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteEntityRequest) Reset()
- func (x *DeleteEntityRequest) String() string
- type DeleteEntityResponse
- func (*DeleteEntityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteEntityResponse) GetId() string
- func (x *DeleteEntityResponse) GetStatus() string
- func (*DeleteEntityResponse) ProtoMessage()
- func (x *DeleteEntityResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteEntityResponse) Reset()
- func (x *DeleteEntityResponse) String() string
- type DeleteSubscriptionRequest
- func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSubscriptionRequest) GetId() string
- func (x *DeleteSubscriptionRequest) GetOwner() string
- func (x *DeleteSubscriptionRequest) GetSource() string
- func (*DeleteSubscriptionRequest) ProtoMessage()
- func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSubscriptionRequest) Reset()
- func (x *DeleteSubscriptionRequest) String() string
- type DeleteSubscriptionResponse
- func (*DeleteSubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSubscriptionResponse) GetId() string
- func (x *DeleteSubscriptionResponse) GetStatus() string
- func (*DeleteSubscriptionResponse) ProtoMessage()
- func (x *DeleteSubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteSubscriptionResponse) Reset()
- func (x *DeleteSubscriptionResponse) String() string
- type DownloadTSDataRequest
- func (*DownloadTSDataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadTSDataRequest) GetEndTime() int64
- func (x *DownloadTSDataRequest) GetId() string
- func (x *DownloadTSDataRequest) GetIdentifiers() string
- func (x *DownloadTSDataRequest) GetStartTime() int64
- func (*DownloadTSDataRequest) ProtoMessage()
- func (x *DownloadTSDataRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadTSDataRequest) Reset()
- func (x *DownloadTSDataRequest) String() string
- type DownloadTSDataResponse
- func (*DownloadTSDataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadTSDataResponse) GetData() []byte
- func (x *DownloadTSDataResponse) GetFilename() string
- func (x *DownloadTSDataResponse) GetLength() string
- func (*DownloadTSDataResponse) ProtoMessage()
- func (x *DownloadTSDataResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadTSDataResponse) Reset()
- func (x *DownloadTSDataResponse) String() string
- type EntityClient
- type EntityHTTPHandler
- func (h *EntityHTTPHandler) AppendMapper(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) CreateEntity(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) DeleteEntity(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) GetEntity(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) GetEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) GetEntityProps(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) GetMapper(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) ListEntity(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) ListMapper(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) PatchEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) PatchEntityConfigsZ(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) PatchEntityProps(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) PatchEntityPropsZ(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) RemoveEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) RemoveEntityProps(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) RemoveMapper(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) UpdateEntity(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) UpdateEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
- func (h *EntityHTTPHandler) UpdateEntityProps(req *go_restful.Request, resp *go_restful.Response)
- type EntityHTTPServer
- type EntityResponse
- func (*EntityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EntityResponse) GetConfigs() *_struct.Value
- func (x *EntityResponse) GetId() string
- func (x *EntityResponse) GetMappers() []*Mapper
- func (x *EntityResponse) GetOwner() string
- func (x *EntityResponse) GetProperties() *_struct.Value
- func (x *EntityResponse) GetSource() string
- func (x *EntityResponse) GetType() string
- func (*EntityResponse) ProtoMessage()
- func (x *EntityResponse) ProtoReflect() protoreflect.Message
- func (x *EntityResponse) Reset()
- func (x *EntityResponse) String() string
- type EntityServer
- type GetEntityConfigsRequest
- func (*GetEntityConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityConfigsRequest) GetId() string
- func (x *GetEntityConfigsRequest) GetOwner() string
- func (x *GetEntityConfigsRequest) GetPropertyKeys() string
- func (x *GetEntityConfigsRequest) GetSource() string
- func (x *GetEntityConfigsRequest) GetType() string
- func (*GetEntityConfigsRequest) ProtoMessage()
- func (x *GetEntityConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *GetEntityConfigsRequest) Reset()
- func (x *GetEntityConfigsRequest) String() string
- type GetEntityPropsRequest
- func (*GetEntityPropsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityPropsRequest) GetId() string
- func (x *GetEntityPropsRequest) GetOwner() string
- func (x *GetEntityPropsRequest) GetPropertyKeys() string
- func (x *GetEntityPropsRequest) GetSource() string
- func (x *GetEntityPropsRequest) GetType() string
- func (*GetEntityPropsRequest) ProtoMessage()
- func (x *GetEntityPropsRequest) ProtoReflect() protoreflect.Message
- func (x *GetEntityPropsRequest) Reset()
- func (x *GetEntityPropsRequest) String() string
- type GetEntityRequest
- func (*GetEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityRequest) GetId() string
- func (x *GetEntityRequest) GetOwner() string
- func (x *GetEntityRequest) GetSource() string
- func (x *GetEntityRequest) GetType() string
- func (*GetEntityRequest) ProtoMessage()
- func (x *GetEntityRequest) ProtoReflect() protoreflect.Message
- func (x *GetEntityRequest) Reset()
- func (x *GetEntityRequest) String() string
- type GetLatestEntitiesRequest
- type GetLatestEntitiesResponse
- func (*GetLatestEntitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLatestEntitiesResponse) GetItems() []*EntityResponse
- func (x *GetLatestEntitiesResponse) GetTotal() int64
- func (*GetLatestEntitiesResponse) ProtoMessage()
- func (x *GetLatestEntitiesResponse) ProtoReflect() protoreflect.Message
- func (x *GetLatestEntitiesResponse) Reset()
- func (x *GetLatestEntitiesResponse) String() string
- type GetMapperRequest
- func (*GetMapperRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMapperRequest) GetEntityId() string
- func (x *GetMapperRequest) GetId() string
- func (x *GetMapperRequest) GetOwner() string
- func (x *GetMapperRequest) GetSource() string
- func (x *GetMapperRequest) GetType() string
- func (*GetMapperRequest) ProtoMessage()
- func (x *GetMapperRequest) ProtoReflect() protoreflect.Message
- func (x *GetMapperRequest) Reset()
- func (x *GetMapperRequest) String() string
- type GetMapperResponse
- func (*GetMapperResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMapperResponse) GetEntityId() string
- func (x *GetMapperResponse) GetMapper() *Mapper
- func (x *GetMapperResponse) GetOwner() string
- func (x *GetMapperResponse) GetSource() string
- func (x *GetMapperResponse) GetType() string
- func (*GetMapperResponse) ProtoMessage()
- func (x *GetMapperResponse) ProtoReflect() protoreflect.Message
- func (x *GetMapperResponse) Reset()
- func (x *GetMapperResponse) String() string
- type GetSubscriptionRequest
- func (*GetSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSubscriptionRequest) GetId() string
- func (x *GetSubscriptionRequest) GetOwner() string
- func (x *GetSubscriptionRequest) GetSource() string
- func (*GetSubscriptionRequest) ProtoMessage()
- func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *GetSubscriptionRequest) Reset()
- func (x *GetSubscriptionRequest) String() string
- type GetTSDataRequest
- func (*GetTSDataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTSDataRequest) GetEndTime() int64
- func (x *GetTSDataRequest) GetId() string
- func (x *GetTSDataRequest) GetIdentifiers() string
- func (x *GetTSDataRequest) GetPageNum() int32
- func (x *GetTSDataRequest) GetPageSize() int32
- func (x *GetTSDataRequest) GetStartTime() int64
- func (*GetTSDataRequest) ProtoMessage()
- func (x *GetTSDataRequest) ProtoReflect() protoreflect.Message
- func (x *GetTSDataRequest) Reset()
- func (x *GetTSDataRequest) String() string
- type GetTSDataResponse
- func (*GetTSDataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTSDataResponse) GetItems() []*TSResponse
- func (x *GetTSDataResponse) GetPageNum() int32
- func (x *GetTSDataResponse) GetPageSize() int32
- func (x *GetTSDataResponse) GetTotal() int32
- func (*GetTSDataResponse) ProtoMessage()
- func (x *GetTSDataResponse) ProtoReflect() protoreflect.Message
- func (x *GetTSDataResponse) Reset()
- func (x *GetTSDataResponse) String() string
- type HealthRequest
- type HealthResponse
- type IndexObject
- type IndexResponse
- type ListEntityRequest
- func (*ListEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListEntityRequest) GetCondition() []*SearchCondition
- func (x *ListEntityRequest) GetIsDescending() bool
- func (x *ListEntityRequest) GetOrderBy() string
- func (x *ListEntityRequest) GetOwner() string
- func (x *ListEntityRequest) GetPageNum() int32
- func (x *ListEntityRequest) GetPageSize() int32
- func (x *ListEntityRequest) GetQuery() string
- func (x *ListEntityRequest) GetSource() string
- func (*ListEntityRequest) ProtoMessage()
- func (x *ListEntityRequest) ProtoReflect() protoreflect.Message
- func (x *ListEntityRequest) Reset()
- func (x *ListEntityRequest) String() string
- type ListEntityResponse
- func (*ListEntityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListEntityResponse) GetItems() []*EntityResponse
- func (x *ListEntityResponse) GetPageNum() int32
- func (x *ListEntityResponse) GetPageSize() int32
- func (x *ListEntityResponse) GetTotal() int32
- func (*ListEntityResponse) ProtoMessage()
- func (x *ListEntityResponse) ProtoReflect() protoreflect.Message
- func (x *ListEntityResponse) Reset()
- func (x *ListEntityResponse) String() string
- type ListMapperRequest
- func (*ListMapperRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListMapperRequest) GetEntityId() string
- func (x *ListMapperRequest) GetOwner() string
- func (x *ListMapperRequest) GetSource() string
- func (x *ListMapperRequest) GetType() string
- func (*ListMapperRequest) ProtoMessage()
- func (x *ListMapperRequest) ProtoReflect() protoreflect.Message
- func (x *ListMapperRequest) Reset()
- func (x *ListMapperRequest) String() string
- type ListMapperResponse
- func (*ListMapperResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMapperResponse) GetEntityId() string
- func (x *ListMapperResponse) GetMappers() []*Mapper
- func (x *ListMapperResponse) GetOwner() string
- func (x *ListMapperResponse) GetSource() string
- func (x *ListMapperResponse) GetType() string
- func (*ListMapperResponse) ProtoMessage()
- func (x *ListMapperResponse) ProtoReflect() protoreflect.Message
- func (x *ListMapperResponse) Reset()
- func (x *ListMapperResponse) String() string
- type ListSubscriptionRequest
- func (*ListSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscriptionRequest) GetOwner() string
- func (x *ListSubscriptionRequest) GetSource() string
- func (*ListSubscriptionRequest) ProtoMessage()
- func (x *ListSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *ListSubscriptionRequest) Reset()
- func (x *ListSubscriptionRequest) String() string
- type ListSubscriptionResponse
- func (*ListSubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscriptionResponse) GetCount() int32
- func (x *ListSubscriptionResponse) GetItems() []*SubscriptionResponse
- func (*ListSubscriptionResponse) ProtoMessage()
- func (x *ListSubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *ListSubscriptionResponse) Reset()
- func (x *ListSubscriptionResponse) String() string
- type Mapper
- func (*Mapper) Descriptor() ([]byte, []int)deprecated
- func (x *Mapper) GetDescription() string
- func (x *Mapper) GetId() string
- func (x *Mapper) GetName() string
- func (x *Mapper) GetTql() string
- func (*Mapper) ProtoMessage()
- func (x *Mapper) ProtoReflect() protoreflect.Message
- func (x *Mapper) Reset()
- func (x *Mapper) String() string
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)deprecated
- func (x *Metadata) GetDatacontenttype() string
- func (x *Metadata) GetId() string
- func (x *Metadata) GetPubsubname() string
- func (x *Metadata) GetSource() string
- func (x *Metadata) GetSpecversion() string
- func (x *Metadata) GetSubject() string
- func (x *Metadata) GetTopic() string
- func (x *Metadata) GetType() string
- func (*Metadata) ProtoMessage()
- func (x *Metadata) ProtoReflect() protoreflect.Message
- func (x *Metadata) Reset()
- func (x *Metadata) String() string
- type Pager
- func (*Pager) Descriptor() ([]byte, []int)deprecated
- func (x *Pager) GetLimit() int32
- func (x *Pager) GetOffset() int32
- func (x *Pager) GetReverse() bool
- func (x *Pager) GetSort() string
- func (*Pager) ProtoMessage()
- func (x *Pager) ProtoReflect() protoreflect.Message
- func (x *Pager) Reset()
- func (x *Pager) String() string
- type PatchData
- func (*PatchData) Descriptor() ([]byte, []int)deprecated
- func (x *PatchData) GetOperator() string
- func (x *PatchData) GetPath() string
- func (x *PatchData) GetValue() *_struct.Value
- func (*PatchData) ProtoMessage()
- func (x *PatchData) ProtoReflect() protoreflect.Message
- func (x *PatchData) Reset()
- func (x *PatchData) String() string
- type PatchDatas
- type PatchEntityConfigsRequest
- func (*PatchEntityConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PatchEntityConfigsRequest) GetConfigs() *_struct.Value
- func (x *PatchEntityConfigsRequest) GetId() string
- func (x *PatchEntityConfigsRequest) GetOwner() string
- func (x *PatchEntityConfigsRequest) GetSource() string
- func (x *PatchEntityConfigsRequest) GetType() string
- func (*PatchEntityConfigsRequest) ProtoMessage()
- func (x *PatchEntityConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *PatchEntityConfigsRequest) Reset()
- func (x *PatchEntityConfigsRequest) String() string
- type PatchEntityPropsRequest
- func (*PatchEntityPropsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PatchEntityPropsRequest) GetId() string
- func (x *PatchEntityPropsRequest) GetOwner() string
- func (x *PatchEntityPropsRequest) GetProperties() *_struct.Value
- func (x *PatchEntityPropsRequest) GetSource() string
- func (x *PatchEntityPropsRequest) GetType() string
- func (*PatchEntityPropsRequest) ProtoMessage()
- func (x *PatchEntityPropsRequest) ProtoReflect() protoreflect.Message
- func (x *PatchEntityPropsRequest) Reset()
- func (x *PatchEntityPropsRequest) String() string
- type ProbeClient
- type ProbeHTTPHandler
- type ProbeHTTPServer
- type ProbeServer
- type ProxyClient
- type ProxyHTTPHandler
- type ProxyHTTPServer
- type ProxyServer
- type RemoveEntityConfigsRequest
- func (*RemoveEntityConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveEntityConfigsRequest) GetId() string
- func (x *RemoveEntityConfigsRequest) GetOwner() string
- func (x *RemoveEntityConfigsRequest) GetPropertyKeys() string
- func (x *RemoveEntityConfigsRequest) GetSource() string
- func (x *RemoveEntityConfigsRequest) GetType() string
- func (*RemoveEntityConfigsRequest) ProtoMessage()
- func (x *RemoveEntityConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveEntityConfigsRequest) Reset()
- func (x *RemoveEntityConfigsRequest) String() string
- type RemoveEntityPropsRequest
- func (*RemoveEntityPropsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveEntityPropsRequest) GetId() string
- func (x *RemoveEntityPropsRequest) GetOwner() string
- func (x *RemoveEntityPropsRequest) GetPropertyKeys() string
- func (x *RemoveEntityPropsRequest) GetSource() string
- func (x *RemoveEntityPropsRequest) GetType() string
- func (*RemoveEntityPropsRequest) ProtoMessage()
- func (x *RemoveEntityPropsRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveEntityPropsRequest) Reset()
- func (x *RemoveEntityPropsRequest) String() string
- type RemoveMapperRequest
- func (*RemoveMapperRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveMapperRequest) GetEntityId() string
- func (x *RemoveMapperRequest) GetId() string
- func (x *RemoveMapperRequest) GetOwner() string
- func (x *RemoveMapperRequest) GetSource() string
- func (x *RemoveMapperRequest) GetType() string
- func (*RemoveMapperRequest) ProtoMessage()
- func (x *RemoveMapperRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveMapperRequest) Reset()
- func (x *RemoveMapperRequest) String() string
- type RemoveMapperResponse
- func (*RemoveMapperResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveMapperResponse) GetEntityId() string
- func (x *RemoveMapperResponse) GetId() string
- func (x *RemoveMapperResponse) GetOwner() string
- func (x *RemoveMapperResponse) GetSource() string
- func (x *RemoveMapperResponse) GetType() string
- func (*RemoveMapperResponse) ProtoMessage()
- func (x *RemoveMapperResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveMapperResponse) Reset()
- func (x *RemoveMapperResponse) String() string
- type RespondRequest
- func (*RespondRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RespondRequest) GetData() []byte
- func (x *RespondRequest) GetMetadata() map[string]string
- func (*RespondRequest) ProtoMessage()
- func (x *RespondRequest) ProtoReflect() protoreflect.Message
- func (x *RespondRequest) Reset()
- func (x *RespondRequest) String() string
- type RespondResponse
- type SearchClient
- type SearchCondition
- func (*SearchCondition) Descriptor() ([]byte, []int)deprecated
- func (x *SearchCondition) GetField() string
- func (x *SearchCondition) GetOperator() string
- func (x *SearchCondition) GetValue() *_struct.Value
- func (*SearchCondition) ProtoMessage()
- func (x *SearchCondition) ProtoReflect() protoreflect.Message
- func (x *SearchCondition) Reset()
- func (x *SearchCondition) String() string
- type SearchHTTPHandler
- type SearchHTTPServer
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRequest) GetCondition() []*SearchCondition
- func (x *SearchRequest) GetIsDescending() bool
- func (x *SearchRequest) GetOrderBy() string
- func (x *SearchRequest) GetOwner() string
- func (x *SearchRequest) GetPageNum() int32
- func (x *SearchRequest) GetPageSize() int32
- func (x *SearchRequest) GetQuery() string
- func (x *SearchRequest) GetSource() string
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) String() string
- type SearchResponse
- func (*SearchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchResponse) GetItems() []*_struct.Value
- func (x *SearchResponse) GetPageNum() int32
- func (x *SearchResponse) GetPageSize() int32
- func (x *SearchResponse) GetTotal() int32
- func (*SearchResponse) ProtoMessage()
- func (x *SearchResponse) ProtoReflect() protoreflect.Message
- func (x *SearchResponse) Reset()
- func (x *SearchResponse) String() string
- type SearchServer
- type SubscriptionClient
- type SubscriptionHTTPHandler
- func (h *SubscriptionHTTPHandler) CreateSubscription(req *go_restful.Request, resp *go_restful.Response)
- func (h *SubscriptionHTTPHandler) DeleteSubscription(req *go_restful.Request, resp *go_restful.Response)
- func (h *SubscriptionHTTPHandler) GetSubscription(req *go_restful.Request, resp *go_restful.Response)
- func (h *SubscriptionHTTPHandler) ListSubscription(req *go_restful.Request, resp *go_restful.Response)
- func (h *SubscriptionHTTPHandler) UpdateSubscription(req *go_restful.Request, resp *go_restful.Response)
- type SubscriptionHTTPServer
- type SubscriptionObject
- func (*SubscriptionObject) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionObject) GetFilter() string
- func (x *SubscriptionObject) GetMode() string
- func (x *SubscriptionObject) GetPubsubName() string
- func (x *SubscriptionObject) GetSource() string
- func (x *SubscriptionObject) GetTarget() string
- func (x *SubscriptionObject) GetTopic() string
- func (*SubscriptionObject) ProtoMessage()
- func (x *SubscriptionObject) ProtoReflect() protoreflect.Message
- func (x *SubscriptionObject) Reset()
- func (x *SubscriptionObject) String() string
- type SubscriptionResponse
- func (*SubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionResponse) GetId() string
- func (x *SubscriptionResponse) GetOwner() string
- func (x *SubscriptionResponse) GetSource() string
- func (x *SubscriptionResponse) GetSubscription() *SubscriptionObject
- func (*SubscriptionResponse) ProtoMessage()
- func (x *SubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *SubscriptionResponse) Reset()
- func (x *SubscriptionResponse) String() string
- type SubscriptionServer
- type TSClient
- type TSHTTPHandler
- type TSHTTPServer
- type TSResponse
- func (*TSResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TSResponse) GetTime() int64
- func (x *TSResponse) GetValue() map[string]float32
- func (*TSResponse) ProtoMessage()
- func (x *TSResponse) ProtoReflect() protoreflect.Message
- func (x *TSResponse) Reset()
- func (x *TSResponse) String() string
- type TSServer
- type TopicClient
- type TopicEventRequest
- func (*TopicEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TopicEventRequest) GetData() *_struct.Value
- func (x *TopicEventRequest) GetDataBase64() string
- func (x *TopicEventRequest) GetMeta() *Metadata
- func (x *TopicEventRequest) GetRawData() []byte
- func (*TopicEventRequest) ProtoMessage()
- func (x *TopicEventRequest) ProtoReflect() protoreflect.Message
- func (x *TopicEventRequest) Reset()
- func (x *TopicEventRequest) String() string
- type TopicEventResponse
- func (*TopicEventResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TopicEventResponse) GetStatus() string
- func (*TopicEventResponse) ProtoMessage()
- func (x *TopicEventResponse) ProtoReflect() protoreflect.Message
- func (x *TopicEventResponse) Reset()
- func (x *TopicEventResponse) String() string
- type TopicHTTPHandler
- type TopicHTTPServer
- type TopicServer
- type UnimplementedEntityServer
- func (UnimplementedEntityServer) AppendMapper(context.Context, *AppendMapperRequest) (*AppendMapperResponse, error)
- func (UnimplementedEntityServer) CreateEntity(context.Context, *CreateEntityRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) DeleteEntity(context.Context, *DeleteEntityRequest) (*DeleteEntityResponse, error)
- func (UnimplementedEntityServer) GetEntity(context.Context, *GetEntityRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) GetEntityConfigs(context.Context, *GetEntityConfigsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) GetEntityProps(context.Context, *GetEntityPropsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) GetMapper(context.Context, *GetMapperRequest) (*GetMapperResponse, error)
- func (UnimplementedEntityServer) ListEntity(context.Context, *ListEntityRequest) (*ListEntityResponse, error)
- func (UnimplementedEntityServer) ListMapper(context.Context, *ListMapperRequest) (*ListMapperResponse, error)
- func (UnimplementedEntityServer) PatchEntityConfigs(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) PatchEntityConfigsZ(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) PatchEntityProps(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) PatchEntityPropsZ(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) RemoveEntityConfigs(context.Context, *RemoveEntityConfigsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) RemoveEntityProps(context.Context, *RemoveEntityPropsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) RemoveMapper(context.Context, *RemoveMapperRequest) (*RemoveMapperResponse, error)
- func (UnimplementedEntityServer) UpdateEntity(context.Context, *UpdateEntityRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) UpdateEntityConfigs(context.Context, *UpdateEntityConfigsRequest) (*EntityResponse, error)
- func (UnimplementedEntityServer) UpdateEntityProps(context.Context, *UpdateEntityPropsRequest) (*EntityResponse, error)
- type UnimplementedProbeServer
- type UnimplementedProxyServer
- type UnimplementedSearchServer
- func (UnimplementedSearchServer) DeleteByID(context.Context, *DeleteByIDRequest) (*DeleteByIDResponse, error)
- func (UnimplementedSearchServer) Index(context.Context, *IndexObject) (*IndexResponse, error)
- func (UnimplementedSearchServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
- type UnimplementedSubscriptionServer
- func (UnimplementedSubscriptionServer) CreateSubscription(context.Context, *CreateSubscriptionRequest) (*SubscriptionResponse, error)
- func (UnimplementedSubscriptionServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error)
- func (UnimplementedSubscriptionServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*SubscriptionResponse, error)
- func (UnimplementedSubscriptionServer) ListSubscription(context.Context, *ListSubscriptionRequest) (*ListSubscriptionResponse, error)
- func (UnimplementedSubscriptionServer) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*SubscriptionResponse, error)
- type UnimplementedTSServer
- func (UnimplementedTSServer) DownloadTSData(context.Context, *DownloadTSDataRequest) (*DownloadTSDataResponse, error)
- func (UnimplementedTSServer) GetLatestEntities(context.Context, *GetLatestEntitiesRequest) (*GetLatestEntitiesResponse, error)
- func (UnimplementedTSServer) GetTSData(context.Context, *GetTSDataRequest) (*GetTSDataResponse, error)
- type UnimplementedTopicServer
- type UnsafeEntityServer
- type UnsafeProbeServer
- type UnsafeProxyServer
- type UnsafeSearchServer
- type UnsafeSubscriptionServer
- type UnsafeTSServer
- type UnsafeTopicServer
- type UpdateEntityConfigsRequest
- func (*UpdateEntityConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateEntityConfigsRequest) GetConfigs() *_struct.Value
- func (x *UpdateEntityConfigsRequest) GetId() string
- func (x *UpdateEntityConfigsRequest) GetOwner() string
- func (x *UpdateEntityConfigsRequest) GetSource() string
- func (x *UpdateEntityConfigsRequest) GetType() string
- func (*UpdateEntityConfigsRequest) ProtoMessage()
- func (x *UpdateEntityConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateEntityConfigsRequest) Reset()
- func (x *UpdateEntityConfigsRequest) String() string
- type UpdateEntityPropsRequest
- func (*UpdateEntityPropsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateEntityPropsRequest) GetId() string
- func (x *UpdateEntityPropsRequest) GetOwner() string
- func (x *UpdateEntityPropsRequest) GetProperties() *_struct.Value
- func (x *UpdateEntityPropsRequest) GetSource() string
- func (x *UpdateEntityPropsRequest) GetType() string
- func (*UpdateEntityPropsRequest) ProtoMessage()
- func (x *UpdateEntityPropsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateEntityPropsRequest) Reset()
- func (x *UpdateEntityPropsRequest) String() string
- type UpdateEntityRequest
- func (*UpdateEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateEntityRequest) GetId() string
- func (x *UpdateEntityRequest) GetOwner() string
- func (x *UpdateEntityRequest) GetProperties() *_struct.Value
- func (x *UpdateEntityRequest) GetSource() string
- func (x *UpdateEntityRequest) GetType() string
- func (*UpdateEntityRequest) ProtoMessage()
- func (x *UpdateEntityRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateEntityRequest) Reset()
- func (x *UpdateEntityRequest) String() string
- type UpdateSubscriptionRequest
- func (*UpdateSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSubscriptionRequest) GetId() string
- func (x *UpdateSubscriptionRequest) GetOwner() string
- func (x *UpdateSubscriptionRequest) GetSource() string
- func (x *UpdateSubscriptionRequest) GetSubscription() *SubscriptionObject
- func (*UpdateSubscriptionRequest) ProtoMessage()
- func (x *UpdateSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSubscriptionRequest) Reset()
- func (x *UpdateSubscriptionRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var Entity_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.core.v1.Entity", HandlerType: (*EntityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateEntity", Handler: _Entity_CreateEntity_Handler, }, { MethodName: "UpdateEntity", Handler: _Entity_UpdateEntity_Handler, }, { MethodName: "GetEntity", Handler: _Entity_GetEntity_Handler, }, { MethodName: "DeleteEntity", Handler: _Entity_DeleteEntity_Handler, }, { MethodName: "UpdateEntityProps", Handler: _Entity_UpdateEntityProps_Handler, }, { MethodName: "PatchEntityProps", Handler: _Entity_PatchEntityProps_Handler, }, { MethodName: "PatchEntityPropsZ", Handler: _Entity_PatchEntityPropsZ_Handler, }, { MethodName: "GetEntityProps", Handler: _Entity_GetEntityProps_Handler, }, { MethodName: "RemoveEntityProps", Handler: _Entity_RemoveEntityProps_Handler, }, { MethodName: "UpdateEntityConfigs", Handler: _Entity_UpdateEntityConfigs_Handler, }, { MethodName: "PatchEntityConfigs", Handler: _Entity_PatchEntityConfigs_Handler, }, { MethodName: "PatchEntityConfigsZ", Handler: _Entity_PatchEntityConfigsZ_Handler, }, { MethodName: "RemoveEntityConfigs", Handler: _Entity_RemoveEntityConfigs_Handler, }, { MethodName: "GetEntityConfigs", Handler: _Entity_GetEntityConfigs_Handler, }, { MethodName: "AppendMapper", Handler: _Entity_AppendMapper_Handler, }, { MethodName: "GetMapper", Handler: _Entity_GetMapper_Handler, }, { MethodName: "ListMapper", Handler: _Entity_ListMapper_Handler, }, { MethodName: "RemoveMapper", Handler: _Entity_RemoveMapper_Handler, }, { MethodName: "ListEntity", Handler: _Entity_ListEntity_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/core/v1/entity.proto", }
Entity_ServiceDesc is the grpc.ServiceDesc for Entity 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_core_v1_entity_proto protoreflect.FileDescriptor
var File_api_core_v1_list_proto protoreflect.FileDescriptor
var File_api_core_v1_probe_proto protoreflect.FileDescriptor
var File_api_core_v1_proxy_proto protoreflect.FileDescriptor
var File_api_core_v1_search_proto protoreflect.FileDescriptor
var File_api_core_v1_subscription_proto protoreflect.FileDescriptor
var File_api_core_v1_topic_proto protoreflect.FileDescriptor
var File_api_core_v1_ts_proto protoreflect.FileDescriptor
var Probe_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.core.v1.Probe", HandlerType: (*ProbeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Health", Handler: _Probe_Health_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/core/v1/probe.proto", }
Probe_ServiceDesc is the grpc.ServiceDesc for Probe service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Proxy_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.core.v1.Proxy", HandlerType: (*ProxyServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Respond", Handler: _Proxy_Respond_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/core/v1/proxy.proto", }
Proxy_ServiceDesc is the grpc.ServiceDesc for Proxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Search_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.core.v1.Search", HandlerType: (*SearchServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Index", Handler: _Search_Index_Handler, }, { MethodName: "Search", Handler: _Search_Search_Handler, }, { MethodName: "DeleteByID", Handler: _Search_DeleteByID_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/core/v1/search.proto", }
Search_ServiceDesc is the grpc.ServiceDesc for Search service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Subscription_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.core.v1.Subscription", HandlerType: (*SubscriptionServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateSubscription", Handler: _Subscription_CreateSubscription_Handler, }, { MethodName: "UpdateSubscription", Handler: _Subscription_UpdateSubscription_Handler, }, { MethodName: "DeleteSubscription", Handler: _Subscription_DeleteSubscription_Handler, }, { MethodName: "GetSubscription", Handler: _Subscription_GetSubscription_Handler, }, { MethodName: "ListSubscription", Handler: _Subscription_ListSubscription_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/core/v1/subscription.proto", }
Subscription_ServiceDesc is the grpc.ServiceDesc for Subscription service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TS_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.core.v1.TS", HandlerType: (*TSServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetTSData", Handler: _TS_GetTSData_Handler, }, { MethodName: "DownloadTSData", Handler: _TS_DownloadTSData_Handler, }, { MethodName: "GetLatestEntities", Handler: _TS_GetLatestEntities_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/core/v1/ts.proto", }
TS_ServiceDesc is the grpc.ServiceDesc for TS service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Topic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.core.v1.Topic", HandlerType: (*TopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "TopicEventHandler", Handler: _Topic_TopicEventHandler_Handler, }, { MethodName: "TopicClusterEventHandler", Handler: _Topic_TopicClusterEventHandler_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/core/v1/topic.proto", }
Topic_ServiceDesc is the grpc.ServiceDesc for Topic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterEntityHTTPServer ¶
func RegisterEntityHTTPServer(container *go_restful.Container, srv EntityHTTPServer)
func RegisterEntityServer ¶
func RegisterEntityServer(s grpc.ServiceRegistrar, srv EntityServer)
func RegisterProbeHTTPServer ¶ added in v0.4.1
func RegisterProbeHTTPServer(container *go_restful.Container, srv ProbeHTTPServer)
func RegisterProbeServer ¶ added in v0.4.1
func RegisterProbeServer(s grpc.ServiceRegistrar, srv ProbeServer)
func RegisterProxyHTTPServer ¶ added in v0.4.1
func RegisterProxyHTTPServer(container *go_restful.Container, srv ProxyHTTPServer)
func RegisterProxyServer ¶ added in v0.4.1
func RegisterProxyServer(s grpc.ServiceRegistrar, srv ProxyServer)
func RegisterSearchHTTPServer ¶
func RegisterSearchHTTPServer(container *go_restful.Container, srv SearchHTTPServer)
func RegisterSearchServer ¶
func RegisterSearchServer(s grpc.ServiceRegistrar, srv SearchServer)
func RegisterSubscriptionHTTPServer ¶
func RegisterSubscriptionHTTPServer(container *go_restful.Container, srv SubscriptionHTTPServer)
func RegisterSubscriptionServer ¶
func RegisterSubscriptionServer(s grpc.ServiceRegistrar, srv SubscriptionServer)
func RegisterTSHTTPServer ¶ added in v0.4.1
func RegisterTSHTTPServer(container *go_restful.Container, srv TSHTTPServer)
func RegisterTSServer ¶ added in v0.4.1
func RegisterTSServer(s grpc.ServiceRegistrar, srv TSServer)
func RegisterTopicHTTPServer ¶
func RegisterTopicHTTPServer(container *go_restful.Container, srv TopicHTTPServer)
func RegisterTopicServer ¶
func RegisterTopicServer(s grpc.ServiceRegistrar, srv TopicServer)
Types ¶
type AppendMapperRequest ¶
type AppendMapperRequest struct { Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` Mapper *Mapper `protobuf:"bytes,6,opt,name=mapper,proto3" json:"mapper,omitempty"` // contains filtered or unexported fields }
Append Mapper Request.
func (*AppendMapperRequest) Descriptor
deprecated
func (*AppendMapperRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppendMapperRequest.ProtoReflect.Descriptor instead.
func (*AppendMapperRequest) GetEntityId ¶ added in v0.4.1
func (x *AppendMapperRequest) GetEntityId() string
func (*AppendMapperRequest) GetMapper ¶
func (x *AppendMapperRequest) GetMapper() *Mapper
func (*AppendMapperRequest) GetOwner ¶
func (x *AppendMapperRequest) GetOwner() string
func (*AppendMapperRequest) GetSource ¶
func (x *AppendMapperRequest) GetSource() string
func (*AppendMapperRequest) GetType ¶ added in v0.3.1
func (x *AppendMapperRequest) GetType() string
func (*AppendMapperRequest) ProtoMessage ¶
func (*AppendMapperRequest) ProtoMessage()
func (*AppendMapperRequest) ProtoReflect ¶
func (x *AppendMapperRequest) ProtoReflect() protoreflect.Message
func (*AppendMapperRequest) Reset ¶
func (x *AppendMapperRequest) Reset()
func (*AppendMapperRequest) String ¶
func (x *AppendMapperRequest) String() string
type AppendMapperResponse ¶ added in v0.4.1
type AppendMapperResponse struct { Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` Mapper *Mapper `protobuf:"bytes,6,opt,name=mapper,proto3" json:"mapper,omitempty"` // contains filtered or unexported fields }
Append Mapper Response.
func (*AppendMapperResponse) Descriptor
deprecated
added in
v0.4.1
func (*AppendMapperResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppendMapperResponse.ProtoReflect.Descriptor instead.
func (*AppendMapperResponse) GetEntityId ¶ added in v0.4.1
func (x *AppendMapperResponse) GetEntityId() string
func (*AppendMapperResponse) GetMapper ¶ added in v0.4.1
func (x *AppendMapperResponse) GetMapper() *Mapper
func (*AppendMapperResponse) GetOwner ¶ added in v0.4.1
func (x *AppendMapperResponse) GetOwner() string
func (*AppendMapperResponse) GetSource ¶ added in v0.4.1
func (x *AppendMapperResponse) GetSource() string
func (*AppendMapperResponse) GetType ¶ added in v0.4.1
func (x *AppendMapperResponse) GetType() string
func (*AppendMapperResponse) ProtoMessage ¶ added in v0.4.1
func (*AppendMapperResponse) ProtoMessage()
func (*AppendMapperResponse) ProtoReflect ¶ added in v0.4.1
func (x *AppendMapperResponse) ProtoReflect() protoreflect.Message
func (*AppendMapperResponse) Reset ¶ added in v0.4.1
func (x *AppendMapperResponse) Reset()
func (*AppendMapperResponse) String ¶ added in v0.4.1
func (x *AppendMapperResponse) String() string
type CreateEntityRequest ¶
type CreateEntityRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` Properties *_struct.Value `protobuf:"bytes,6,opt,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
Create Entity Request.
func (*CreateEntityRequest) Descriptor
deprecated
func (*CreateEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateEntityRequest.ProtoReflect.Descriptor instead.
func (*CreateEntityRequest) GetFrom ¶ added in v0.3.0
func (x *CreateEntityRequest) GetFrom() string
func (*CreateEntityRequest) GetId ¶
func (x *CreateEntityRequest) GetId() string
func (*CreateEntityRequest) GetOwner ¶
func (x *CreateEntityRequest) GetOwner() string
func (*CreateEntityRequest) GetProperties ¶
func (x *CreateEntityRequest) GetProperties() *_struct.Value
func (*CreateEntityRequest) GetSource ¶
func (x *CreateEntityRequest) GetSource() string
func (*CreateEntityRequest) GetType ¶
func (x *CreateEntityRequest) GetType() string
func (*CreateEntityRequest) ProtoMessage ¶
func (*CreateEntityRequest) ProtoMessage()
func (*CreateEntityRequest) ProtoReflect ¶
func (x *CreateEntityRequest) ProtoReflect() protoreflect.Message
func (*CreateEntityRequest) Reset ¶
func (x *CreateEntityRequest) Reset()
func (*CreateEntityRequest) String ¶
func (x *CreateEntityRequest) String() string
type CreateSubscriptionRequest ¶
type CreateSubscriptionRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Subscription *SubscriptionObject `protobuf:"bytes,5,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
func (*CreateSubscriptionRequest) Descriptor
deprecated
func (*CreateSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*CreateSubscriptionRequest) GetId ¶
func (x *CreateSubscriptionRequest) GetId() string
func (*CreateSubscriptionRequest) GetOwner ¶
func (x *CreateSubscriptionRequest) GetOwner() string
func (*CreateSubscriptionRequest) GetSource ¶
func (x *CreateSubscriptionRequest) GetSource() string
func (*CreateSubscriptionRequest) GetSubscription ¶
func (x *CreateSubscriptionRequest) GetSubscription() *SubscriptionObject
func (*CreateSubscriptionRequest) ProtoMessage ¶
func (*CreateSubscriptionRequest) ProtoMessage()
func (*CreateSubscriptionRequest) ProtoReflect ¶
func (x *CreateSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*CreateSubscriptionRequest) Reset ¶
func (x *CreateSubscriptionRequest) Reset()
func (*CreateSubscriptionRequest) String ¶
func (x *CreateSubscriptionRequest) String() string
type DeleteByIDRequest ¶ added in v0.3.0
type DeleteByIDRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*DeleteByIDRequest) Descriptor
deprecated
added in
v0.3.0
func (*DeleteByIDRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteByIDRequest.ProtoReflect.Descriptor instead.
func (*DeleteByIDRequest) GetId ¶ added in v0.3.0
func (x *DeleteByIDRequest) GetId() string
func (*DeleteByIDRequest) GetOwner ¶ added in v0.3.0
func (x *DeleteByIDRequest) GetOwner() string
func (*DeleteByIDRequest) GetSource ¶ added in v0.3.0
func (x *DeleteByIDRequest) GetSource() string
func (*DeleteByIDRequest) ProtoMessage ¶ added in v0.3.0
func (*DeleteByIDRequest) ProtoMessage()
func (*DeleteByIDRequest) ProtoReflect ¶ added in v0.3.0
func (x *DeleteByIDRequest) ProtoReflect() protoreflect.Message
func (*DeleteByIDRequest) Reset ¶ added in v0.3.0
func (x *DeleteByIDRequest) Reset()
func (*DeleteByIDRequest) String ¶ added in v0.3.0
func (x *DeleteByIDRequest) String() string
type DeleteByIDResponse ¶ added in v0.3.0
type DeleteByIDResponse struct {
// contains filtered or unexported fields
}
func (*DeleteByIDResponse) Descriptor
deprecated
added in
v0.3.0
func (*DeleteByIDResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteByIDResponse.ProtoReflect.Descriptor instead.
func (*DeleteByIDResponse) ProtoMessage ¶ added in v0.3.0
func (*DeleteByIDResponse) ProtoMessage()
func (*DeleteByIDResponse) ProtoReflect ¶ added in v0.3.0
func (x *DeleteByIDResponse) ProtoReflect() protoreflect.Message
func (*DeleteByIDResponse) Reset ¶ added in v0.3.0
func (x *DeleteByIDResponse) Reset()
func (*DeleteByIDResponse) String ¶ added in v0.3.0
func (x *DeleteByIDResponse) String() string
type DeleteEntityRequest ¶
type DeleteEntityRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
Delete Entity Request.
func (*DeleteEntityRequest) Descriptor
deprecated
func (*DeleteEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEntityRequest.ProtoReflect.Descriptor instead.
func (*DeleteEntityRequest) GetId ¶
func (x *DeleteEntityRequest) GetId() string
func (*DeleteEntityRequest) GetOwner ¶
func (x *DeleteEntityRequest) GetOwner() string
func (*DeleteEntityRequest) GetSource ¶
func (x *DeleteEntityRequest) GetSource() string
func (*DeleteEntityRequest) GetType ¶ added in v0.3.1
func (x *DeleteEntityRequest) GetType() string
func (*DeleteEntityRequest) ProtoMessage ¶
func (*DeleteEntityRequest) ProtoMessage()
func (*DeleteEntityRequest) ProtoReflect ¶
func (x *DeleteEntityRequest) ProtoReflect() protoreflect.Message
func (*DeleteEntityRequest) Reset ¶
func (x *DeleteEntityRequest) Reset()
func (*DeleteEntityRequest) String ¶
func (x *DeleteEntityRequest) String() string
type DeleteEntityResponse ¶
type DeleteEntityResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
Delete Entity Response.
func (*DeleteEntityResponse) Descriptor
deprecated
func (*DeleteEntityResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEntityResponse.ProtoReflect.Descriptor instead.
func (*DeleteEntityResponse) GetId ¶
func (x *DeleteEntityResponse) GetId() string
func (*DeleteEntityResponse) GetStatus ¶
func (x *DeleteEntityResponse) GetStatus() string
func (*DeleteEntityResponse) ProtoMessage ¶
func (*DeleteEntityResponse) ProtoMessage()
func (*DeleteEntityResponse) ProtoReflect ¶
func (x *DeleteEntityResponse) ProtoReflect() protoreflect.Message
func (*DeleteEntityResponse) Reset ¶
func (x *DeleteEntityResponse) Reset()
func (*DeleteEntityResponse) String ¶
func (x *DeleteEntityResponse) String() string
type DeleteSubscriptionRequest ¶
type DeleteSubscriptionRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*DeleteSubscriptionRequest) Descriptor
deprecated
func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*DeleteSubscriptionRequest) GetId ¶
func (x *DeleteSubscriptionRequest) GetId() string
func (*DeleteSubscriptionRequest) GetOwner ¶
func (x *DeleteSubscriptionRequest) GetOwner() string
func (*DeleteSubscriptionRequest) GetSource ¶
func (x *DeleteSubscriptionRequest) GetSource() string
func (*DeleteSubscriptionRequest) ProtoMessage ¶
func (*DeleteSubscriptionRequest) ProtoMessage()
func (*DeleteSubscriptionRequest) ProtoReflect ¶
func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*DeleteSubscriptionRequest) Reset ¶
func (x *DeleteSubscriptionRequest) Reset()
func (*DeleteSubscriptionRequest) String ¶
func (x *DeleteSubscriptionRequest) String() string
type DeleteSubscriptionResponse ¶
type DeleteSubscriptionResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*DeleteSubscriptionResponse) Descriptor
deprecated
func (*DeleteSubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSubscriptionResponse.ProtoReflect.Descriptor instead.
func (*DeleteSubscriptionResponse) GetId ¶
func (x *DeleteSubscriptionResponse) GetId() string
func (*DeleteSubscriptionResponse) GetStatus ¶
func (x *DeleteSubscriptionResponse) GetStatus() string
func (*DeleteSubscriptionResponse) ProtoMessage ¶
func (*DeleteSubscriptionResponse) ProtoMessage()
func (*DeleteSubscriptionResponse) ProtoReflect ¶
func (x *DeleteSubscriptionResponse) ProtoReflect() protoreflect.Message
func (*DeleteSubscriptionResponse) Reset ¶
func (x *DeleteSubscriptionResponse) Reset()
func (*DeleteSubscriptionResponse) String ¶
func (x *DeleteSubscriptionResponse) String() string
type DownloadTSDataRequest ¶ added in v0.4.1
type DownloadTSDataRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` StartTime int64 `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime int64 `protobuf:"varint,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Identifiers string `protobuf:"bytes,4,opt,name=identifiers,proto3" json:"identifiers,omitempty"` // contains filtered or unexported fields }
func (*DownloadTSDataRequest) Descriptor
deprecated
added in
v0.4.1
func (*DownloadTSDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadTSDataRequest.ProtoReflect.Descriptor instead.
func (*DownloadTSDataRequest) GetEndTime ¶ added in v0.4.1
func (x *DownloadTSDataRequest) GetEndTime() int64
func (*DownloadTSDataRequest) GetId ¶ added in v0.4.1
func (x *DownloadTSDataRequest) GetId() string
func (*DownloadTSDataRequest) GetIdentifiers ¶ added in v0.4.1
func (x *DownloadTSDataRequest) GetIdentifiers() string
func (*DownloadTSDataRequest) GetStartTime ¶ added in v0.4.1
func (x *DownloadTSDataRequest) GetStartTime() int64
func (*DownloadTSDataRequest) ProtoMessage ¶ added in v0.4.1
func (*DownloadTSDataRequest) ProtoMessage()
func (*DownloadTSDataRequest) ProtoReflect ¶ added in v0.4.1
func (x *DownloadTSDataRequest) ProtoReflect() protoreflect.Message
func (*DownloadTSDataRequest) Reset ¶ added in v0.4.1
func (x *DownloadTSDataRequest) Reset()
func (*DownloadTSDataRequest) String ¶ added in v0.4.1
func (x *DownloadTSDataRequest) String() string
type DownloadTSDataResponse ¶ added in v0.4.1
type DownloadTSDataResponse struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Length string `protobuf:"bytes,2,opt,name=length,proto3" json:"length,omitempty"` Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"` // contains filtered or unexported fields }
func (*DownloadTSDataResponse) Descriptor
deprecated
added in
v0.4.1
func (*DownloadTSDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadTSDataResponse.ProtoReflect.Descriptor instead.
func (*DownloadTSDataResponse) GetData ¶ added in v0.4.1
func (x *DownloadTSDataResponse) GetData() []byte
func (*DownloadTSDataResponse) GetFilename ¶ added in v0.4.1
func (x *DownloadTSDataResponse) GetFilename() string
func (*DownloadTSDataResponse) GetLength ¶ added in v0.4.1
func (x *DownloadTSDataResponse) GetLength() string
func (*DownloadTSDataResponse) ProtoMessage ¶ added in v0.4.1
func (*DownloadTSDataResponse) ProtoMessage()
func (*DownloadTSDataResponse) ProtoReflect ¶ added in v0.4.1
func (x *DownloadTSDataResponse) ProtoReflect() protoreflect.Message
func (*DownloadTSDataResponse) Reset ¶ added in v0.4.1
func (x *DownloadTSDataResponse) Reset()
func (*DownloadTSDataResponse) String ¶ added in v0.4.1
func (x *DownloadTSDataResponse) String() string
type EntityClient ¶
type EntityClient interface { CreateEntity(ctx context.Context, in *CreateEntityRequest, opts ...grpc.CallOption) (*EntityResponse, error) UpdateEntity(ctx context.Context, in *UpdateEntityRequest, opts ...grpc.CallOption) (*EntityResponse, error) GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*EntityResponse, error) DeleteEntity(ctx context.Context, in *DeleteEntityRequest, opts ...grpc.CallOption) (*DeleteEntityResponse, error) UpdateEntityProps(ctx context.Context, in *UpdateEntityPropsRequest, opts ...grpc.CallOption) (*EntityResponse, error) PatchEntityProps(ctx context.Context, in *PatchEntityPropsRequest, opts ...grpc.CallOption) (*EntityResponse, error) PatchEntityPropsZ(ctx context.Context, in *PatchEntityPropsRequest, opts ...grpc.CallOption) (*EntityResponse, error) GetEntityProps(ctx context.Context, in *GetEntityPropsRequest, opts ...grpc.CallOption) (*EntityResponse, error) RemoveEntityProps(ctx context.Context, in *RemoveEntityPropsRequest, opts ...grpc.CallOption) (*EntityResponse, error) UpdateEntityConfigs(ctx context.Context, in *UpdateEntityConfigsRequest, opts ...grpc.CallOption) (*EntityResponse, error) PatchEntityConfigs(ctx context.Context, in *PatchEntityConfigsRequest, opts ...grpc.CallOption) (*EntityResponse, error) PatchEntityConfigsZ(ctx context.Context, in *PatchEntityConfigsRequest, opts ...grpc.CallOption) (*EntityResponse, error) RemoveEntityConfigs(ctx context.Context, in *RemoveEntityConfigsRequest, opts ...grpc.CallOption) (*EntityResponse, error) GetEntityConfigs(ctx context.Context, in *GetEntityConfigsRequest, opts ...grpc.CallOption) (*EntityResponse, error) AppendMapper(ctx context.Context, in *AppendMapperRequest, opts ...grpc.CallOption) (*AppendMapperResponse, error) GetMapper(ctx context.Context, in *GetMapperRequest, opts ...grpc.CallOption) (*GetMapperResponse, error) ListMapper(ctx context.Context, in *ListMapperRequest, opts ...grpc.CallOption) (*ListMapperResponse, error) RemoveMapper(ctx context.Context, in *RemoveMapperRequest, opts ...grpc.CallOption) (*RemoveMapperResponse, error) ListEntity(ctx context.Context, in *ListEntityRequest, opts ...grpc.CallOption) (*ListEntityResponse, error) }
EntityClient is the client API for Entity 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 NewEntityClient ¶
func NewEntityClient(cc grpc.ClientConnInterface) EntityClient
type EntityHTTPHandler ¶
type EntityHTTPHandler struct {
// contains filtered or unexported fields
}
func (*EntityHTTPHandler) AppendMapper ¶
func (h *EntityHTTPHandler) AppendMapper(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) CreateEntity ¶
func (h *EntityHTTPHandler) CreateEntity(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) DeleteEntity ¶
func (h *EntityHTTPHandler) DeleteEntity(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) GetEntity ¶
func (h *EntityHTTPHandler) GetEntity(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) GetEntityConfigs ¶ added in v0.4.1
func (h *EntityHTTPHandler) GetEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) GetEntityProps ¶ added in v0.3.0
func (h *EntityHTTPHandler) GetEntityProps(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) GetMapper ¶ added in v0.4.1
func (h *EntityHTTPHandler) GetMapper(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) ListEntity ¶
func (h *EntityHTTPHandler) ListEntity(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) ListMapper ¶ added in v0.4.1
func (h *EntityHTTPHandler) ListMapper(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) PatchEntityConfigs ¶ added in v0.4.1
func (h *EntityHTTPHandler) PatchEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) PatchEntityConfigsZ ¶ added in v0.4.1
func (h *EntityHTTPHandler) PatchEntityConfigsZ(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) PatchEntityProps ¶ added in v0.4.1
func (h *EntityHTTPHandler) PatchEntityProps(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) PatchEntityPropsZ ¶ added in v0.4.1
func (h *EntityHTTPHandler) PatchEntityPropsZ(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) RemoveEntityConfigs ¶ added in v0.4.1
func (h *EntityHTTPHandler) RemoveEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) RemoveEntityProps ¶ added in v0.4.1
func (h *EntityHTTPHandler) RemoveEntityProps(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) RemoveMapper ¶ added in v0.3.1
func (h *EntityHTTPHandler) RemoveMapper(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) UpdateEntity ¶
func (h *EntityHTTPHandler) UpdateEntity(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) UpdateEntityConfigs ¶ added in v0.4.1
func (h *EntityHTTPHandler) UpdateEntityConfigs(req *go_restful.Request, resp *go_restful.Response)
func (*EntityHTTPHandler) UpdateEntityProps ¶ added in v0.4.1
func (h *EntityHTTPHandler) UpdateEntityProps(req *go_restful.Request, resp *go_restful.Response)
type EntityHTTPServer ¶
type EntityHTTPServer interface { AppendMapper(context.Context, *AppendMapperRequest) (*AppendMapperResponse, error) CreateEntity(context.Context, *CreateEntityRequest) (*EntityResponse, error) DeleteEntity(context.Context, *DeleteEntityRequest) (*DeleteEntityResponse, error) GetEntity(context.Context, *GetEntityRequest) (*EntityResponse, error) GetEntityConfigs(context.Context, *GetEntityConfigsRequest) (*EntityResponse, error) GetEntityProps(context.Context, *GetEntityPropsRequest) (*EntityResponse, error) GetMapper(context.Context, *GetMapperRequest) (*GetMapperResponse, error) ListEntity(context.Context, *ListEntityRequest) (*ListEntityResponse, error) ListMapper(context.Context, *ListMapperRequest) (*ListMapperResponse, error) PatchEntityConfigs(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error) PatchEntityConfigsZ(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error) PatchEntityProps(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error) PatchEntityPropsZ(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error) RemoveEntityConfigs(context.Context, *RemoveEntityConfigsRequest) (*EntityResponse, error) RemoveEntityProps(context.Context, *RemoveEntityPropsRequest) (*EntityResponse, error) RemoveMapper(context.Context, *RemoveMapperRequest) (*RemoveMapperResponse, error) UpdateEntity(context.Context, *UpdateEntityRequest) (*EntityResponse, error) UpdateEntityConfigs(context.Context, *UpdateEntityConfigsRequest) (*EntityResponse, error) UpdateEntityProps(context.Context, *UpdateEntityPropsRequest) (*EntityResponse, error) }
type EntityResponse ¶
type EntityResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` Mappers []*Mapper `protobuf:"bytes,6,rep,name=mappers,proto3" json:"mappers,omitempty"` Configs *_struct.Value `protobuf:"bytes,7,opt,name=configs,proto3" json:"configs,omitempty"` Properties *_struct.Value `protobuf:"bytes,8,opt,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
Entity Response.
func (*EntityResponse) Descriptor
deprecated
func (*EntityResponse) Descriptor() ([]byte, []int)
Deprecated: Use EntityResponse.ProtoReflect.Descriptor instead.
func (*EntityResponse) GetConfigs ¶
func (x *EntityResponse) GetConfigs() *_struct.Value
func (*EntityResponse) GetId ¶
func (x *EntityResponse) GetId() string
func (*EntityResponse) GetMappers ¶
func (x *EntityResponse) GetMappers() []*Mapper
func (*EntityResponse) GetOwner ¶
func (x *EntityResponse) GetOwner() string
func (*EntityResponse) GetProperties ¶
func (x *EntityResponse) GetProperties() *_struct.Value
func (*EntityResponse) GetSource ¶
func (x *EntityResponse) GetSource() string
func (*EntityResponse) GetType ¶
func (x *EntityResponse) GetType() string
func (*EntityResponse) ProtoMessage ¶
func (*EntityResponse) ProtoMessage()
func (*EntityResponse) ProtoReflect ¶
func (x *EntityResponse) ProtoReflect() protoreflect.Message
func (*EntityResponse) Reset ¶
func (x *EntityResponse) Reset()
func (*EntityResponse) String ¶
func (x *EntityResponse) String() string
type EntityServer ¶
type EntityServer interface { CreateEntity(context.Context, *CreateEntityRequest) (*EntityResponse, error) UpdateEntity(context.Context, *UpdateEntityRequest) (*EntityResponse, error) GetEntity(context.Context, *GetEntityRequest) (*EntityResponse, error) DeleteEntity(context.Context, *DeleteEntityRequest) (*DeleteEntityResponse, error) UpdateEntityProps(context.Context, *UpdateEntityPropsRequest) (*EntityResponse, error) PatchEntityProps(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error) PatchEntityPropsZ(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error) GetEntityProps(context.Context, *GetEntityPropsRequest) (*EntityResponse, error) RemoveEntityProps(context.Context, *RemoveEntityPropsRequest) (*EntityResponse, error) UpdateEntityConfigs(context.Context, *UpdateEntityConfigsRequest) (*EntityResponse, error) PatchEntityConfigs(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error) PatchEntityConfigsZ(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error) RemoveEntityConfigs(context.Context, *RemoveEntityConfigsRequest) (*EntityResponse, error) GetEntityConfigs(context.Context, *GetEntityConfigsRequest) (*EntityResponse, error) AppendMapper(context.Context, *AppendMapperRequest) (*AppendMapperResponse, error) GetMapper(context.Context, *GetMapperRequest) (*GetMapperResponse, error) ListMapper(context.Context, *ListMapperRequest) (*ListMapperResponse, error) RemoveMapper(context.Context, *RemoveMapperRequest) (*RemoveMapperResponse, error) ListEntity(context.Context, *ListEntityRequest) (*ListEntityResponse, error) // contains filtered or unexported methods }
EntityServer is the server API for Entity service. All implementations must embed UnimplementedEntityServer for forward compatibility
type GetEntityConfigsRequest ¶ added in v0.4.1
type GetEntityConfigsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` PropertyKeys string `protobuf:"bytes,5,opt,name=property_keys,json=propertyKeys,proto3" json:"property_keys,omitempty"` // contains filtered or unexported fields }
Get Entity Configs Request.
func (*GetEntityConfigsRequest) Descriptor
deprecated
added in
v0.4.1
func (*GetEntityConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityConfigsRequest.ProtoReflect.Descriptor instead.
func (*GetEntityConfigsRequest) GetId ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) GetId() string
func (*GetEntityConfigsRequest) GetOwner ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) GetOwner() string
func (*GetEntityConfigsRequest) GetPropertyKeys ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) GetPropertyKeys() string
func (*GetEntityConfigsRequest) GetSource ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) GetSource() string
func (*GetEntityConfigsRequest) GetType ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) GetType() string
func (*GetEntityConfigsRequest) ProtoMessage ¶ added in v0.4.1
func (*GetEntityConfigsRequest) ProtoMessage()
func (*GetEntityConfigsRequest) ProtoReflect ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) ProtoReflect() protoreflect.Message
func (*GetEntityConfigsRequest) Reset ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) Reset()
func (*GetEntityConfigsRequest) String ¶ added in v0.4.1
func (x *GetEntityConfigsRequest) String() string
type GetEntityPropsRequest ¶ added in v0.3.0
type GetEntityPropsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` PropertyKeys string `protobuf:"bytes,6,opt,name=property_keys,json=propertyKeys,proto3" json:"property_keys,omitempty"` // contains filtered or unexported fields }
Get Entity Properties Request.
func (*GetEntityPropsRequest) Descriptor
deprecated
added in
v0.3.0
func (*GetEntityPropsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityPropsRequest.ProtoReflect.Descriptor instead.
func (*GetEntityPropsRequest) GetId ¶ added in v0.3.0
func (x *GetEntityPropsRequest) GetId() string
func (*GetEntityPropsRequest) GetOwner ¶ added in v0.3.0
func (x *GetEntityPropsRequest) GetOwner() string
func (*GetEntityPropsRequest) GetPropertyKeys ¶ added in v0.4.1
func (x *GetEntityPropsRequest) GetPropertyKeys() string
func (*GetEntityPropsRequest) GetSource ¶ added in v0.3.0
func (x *GetEntityPropsRequest) GetSource() string
func (*GetEntityPropsRequest) GetType ¶ added in v0.3.0
func (x *GetEntityPropsRequest) GetType() string
func (*GetEntityPropsRequest) ProtoMessage ¶ added in v0.3.0
func (*GetEntityPropsRequest) ProtoMessage()
func (*GetEntityPropsRequest) ProtoReflect ¶ added in v0.3.0
func (x *GetEntityPropsRequest) ProtoReflect() protoreflect.Message
func (*GetEntityPropsRequest) Reset ¶ added in v0.3.0
func (x *GetEntityPropsRequest) Reset()
func (*GetEntityPropsRequest) String ¶ added in v0.3.0
func (x *GetEntityPropsRequest) String() string
type GetEntityRequest ¶
type GetEntityRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
Get Entity Request.
func (*GetEntityRequest) Descriptor
deprecated
func (*GetEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.
func (*GetEntityRequest) GetId ¶
func (x *GetEntityRequest) GetId() string
func (*GetEntityRequest) GetOwner ¶
func (x *GetEntityRequest) GetOwner() string
func (*GetEntityRequest) GetSource ¶
func (x *GetEntityRequest) GetSource() string
func (*GetEntityRequest) GetType ¶ added in v0.3.1
func (x *GetEntityRequest) GetType() string
func (*GetEntityRequest) ProtoMessage ¶
func (*GetEntityRequest) ProtoMessage()
func (*GetEntityRequest) ProtoReflect ¶
func (x *GetEntityRequest) ProtoReflect() protoreflect.Message
func (*GetEntityRequest) Reset ¶
func (x *GetEntityRequest) Reset()
func (*GetEntityRequest) String ¶
func (x *GetEntityRequest) String() string
type GetLatestEntitiesRequest ¶ added in v0.4.1
type GetLatestEntitiesRequest struct {
// contains filtered or unexported fields
}
func (*GetLatestEntitiesRequest) Descriptor
deprecated
added in
v0.4.1
func (*GetLatestEntitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLatestEntitiesRequest.ProtoReflect.Descriptor instead.
func (*GetLatestEntitiesRequest) ProtoMessage ¶ added in v0.4.1
func (*GetLatestEntitiesRequest) ProtoMessage()
func (*GetLatestEntitiesRequest) ProtoReflect ¶ added in v0.4.1
func (x *GetLatestEntitiesRequest) ProtoReflect() protoreflect.Message
func (*GetLatestEntitiesRequest) Reset ¶ added in v0.4.1
func (x *GetLatestEntitiesRequest) Reset()
func (*GetLatestEntitiesRequest) String ¶ added in v0.4.1
func (x *GetLatestEntitiesRequest) String() string
type GetLatestEntitiesResponse ¶ added in v0.4.1
type GetLatestEntitiesResponse struct { Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Items []*EntityResponse `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*GetLatestEntitiesResponse) Descriptor
deprecated
added in
v0.4.1
func (*GetLatestEntitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLatestEntitiesResponse.ProtoReflect.Descriptor instead.
func (*GetLatestEntitiesResponse) GetItems ¶ added in v0.4.1
func (x *GetLatestEntitiesResponse) GetItems() []*EntityResponse
func (*GetLatestEntitiesResponse) GetTotal ¶ added in v0.4.1
func (x *GetLatestEntitiesResponse) GetTotal() int64
func (*GetLatestEntitiesResponse) ProtoMessage ¶ added in v0.4.1
func (*GetLatestEntitiesResponse) ProtoMessage()
func (*GetLatestEntitiesResponse) ProtoReflect ¶ added in v0.4.1
func (x *GetLatestEntitiesResponse) ProtoReflect() protoreflect.Message
func (*GetLatestEntitiesResponse) Reset ¶ added in v0.4.1
func (x *GetLatestEntitiesResponse) Reset()
func (*GetLatestEntitiesResponse) String ¶ added in v0.4.1
func (x *GetLatestEntitiesResponse) String() string
type GetMapperRequest ¶ added in v0.4.1
type GetMapperRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` // contains filtered or unexported fields }
Get Mapper Request.
func (*GetMapperRequest) Descriptor
deprecated
added in
v0.4.1
func (*GetMapperRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMapperRequest.ProtoReflect.Descriptor instead.
func (*GetMapperRequest) GetEntityId ¶ added in v0.4.1
func (x *GetMapperRequest) GetEntityId() string
func (*GetMapperRequest) GetId ¶ added in v0.4.1
func (x *GetMapperRequest) GetId() string
func (*GetMapperRequest) GetOwner ¶ added in v0.4.1
func (x *GetMapperRequest) GetOwner() string
func (*GetMapperRequest) GetSource ¶ added in v0.4.1
func (x *GetMapperRequest) GetSource() string
func (*GetMapperRequest) GetType ¶ added in v0.4.1
func (x *GetMapperRequest) GetType() string
func (*GetMapperRequest) ProtoMessage ¶ added in v0.4.1
func (*GetMapperRequest) ProtoMessage()
func (*GetMapperRequest) ProtoReflect ¶ added in v0.4.1
func (x *GetMapperRequest) ProtoReflect() protoreflect.Message
func (*GetMapperRequest) Reset ¶ added in v0.4.1
func (x *GetMapperRequest) Reset()
func (*GetMapperRequest) String ¶ added in v0.4.1
func (x *GetMapperRequest) String() string
type GetMapperResponse ¶ added in v0.4.1
type GetMapperResponse struct { Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` Mapper *Mapper `protobuf:"bytes,6,opt,name=mapper,proto3" json:"mapper,omitempty"` // contains filtered or unexported fields }
Get Mapper Response.
func (*GetMapperResponse) Descriptor
deprecated
added in
v0.4.1
func (*GetMapperResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMapperResponse.ProtoReflect.Descriptor instead.
func (*GetMapperResponse) GetEntityId ¶ added in v0.4.1
func (x *GetMapperResponse) GetEntityId() string
func (*GetMapperResponse) GetMapper ¶ added in v0.4.1
func (x *GetMapperResponse) GetMapper() *Mapper
func (*GetMapperResponse) GetOwner ¶ added in v0.4.1
func (x *GetMapperResponse) GetOwner() string
func (*GetMapperResponse) GetSource ¶ added in v0.4.1
func (x *GetMapperResponse) GetSource() string
func (*GetMapperResponse) GetType ¶ added in v0.4.1
func (x *GetMapperResponse) GetType() string
func (*GetMapperResponse) ProtoMessage ¶ added in v0.4.1
func (*GetMapperResponse) ProtoMessage()
func (*GetMapperResponse) ProtoReflect ¶ added in v0.4.1
func (x *GetMapperResponse) ProtoReflect() protoreflect.Message
func (*GetMapperResponse) Reset ¶ added in v0.4.1
func (x *GetMapperResponse) Reset()
func (*GetMapperResponse) String ¶ added in v0.4.1
func (x *GetMapperResponse) String() string
type GetSubscriptionRequest ¶
type GetSubscriptionRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*GetSubscriptionRequest) Descriptor
deprecated
func (*GetSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*GetSubscriptionRequest) GetId ¶
func (x *GetSubscriptionRequest) GetId() string
func (*GetSubscriptionRequest) GetOwner ¶
func (x *GetSubscriptionRequest) GetOwner() string
func (*GetSubscriptionRequest) GetSource ¶
func (x *GetSubscriptionRequest) GetSource() string
func (*GetSubscriptionRequest) ProtoMessage ¶
func (*GetSubscriptionRequest) ProtoMessage()
func (*GetSubscriptionRequest) ProtoReflect ¶
func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*GetSubscriptionRequest) Reset ¶
func (x *GetSubscriptionRequest) Reset()
func (*GetSubscriptionRequest) String ¶
func (x *GetSubscriptionRequest) String() string
type GetTSDataRequest ¶ added in v0.4.1
type GetTSDataRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` StartTime int64 `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime int64 `protobuf:"varint,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Identifiers string `protobuf:"bytes,4,opt,name=identifiers,proto3" json:"identifiers,omitempty"` PageNum int32 `protobuf:"varint,5,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"` PageSize int32 `protobuf:"varint,6,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // contains filtered or unexported fields }
func (*GetTSDataRequest) Descriptor
deprecated
added in
v0.4.1
func (*GetTSDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTSDataRequest.ProtoReflect.Descriptor instead.
func (*GetTSDataRequest) GetEndTime ¶ added in v0.4.1
func (x *GetTSDataRequest) GetEndTime() int64
func (*GetTSDataRequest) GetId ¶ added in v0.4.1
func (x *GetTSDataRequest) GetId() string
func (*GetTSDataRequest) GetIdentifiers ¶ added in v0.4.1
func (x *GetTSDataRequest) GetIdentifiers() string
func (*GetTSDataRequest) GetPageNum ¶ added in v0.4.1
func (x *GetTSDataRequest) GetPageNum() int32
func (*GetTSDataRequest) GetPageSize ¶ added in v0.4.1
func (x *GetTSDataRequest) GetPageSize() int32
func (*GetTSDataRequest) GetStartTime ¶ added in v0.4.1
func (x *GetTSDataRequest) GetStartTime() int64
func (*GetTSDataRequest) ProtoMessage ¶ added in v0.4.1
func (*GetTSDataRequest) ProtoMessage()
func (*GetTSDataRequest) ProtoReflect ¶ added in v0.4.1
func (x *GetTSDataRequest) ProtoReflect() protoreflect.Message
func (*GetTSDataRequest) Reset ¶ added in v0.4.1
func (x *GetTSDataRequest) Reset()
func (*GetTSDataRequest) String ¶ added in v0.4.1
func (x *GetTSDataRequest) String() string
type GetTSDataResponse ¶ added in v0.4.1
type GetTSDataResponse struct { Total int32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` PageNum int32 `protobuf:"varint,2,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"` PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Items []*TSResponse `protobuf:"bytes,5,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*GetTSDataResponse) Descriptor
deprecated
added in
v0.4.1
func (*GetTSDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTSDataResponse.ProtoReflect.Descriptor instead.
func (*GetTSDataResponse) GetItems ¶ added in v0.4.1
func (x *GetTSDataResponse) GetItems() []*TSResponse
func (*GetTSDataResponse) GetPageNum ¶ added in v0.4.1
func (x *GetTSDataResponse) GetPageNum() int32
func (*GetTSDataResponse) GetPageSize ¶ added in v0.4.1
func (x *GetTSDataResponse) GetPageSize() int32
func (*GetTSDataResponse) GetTotal ¶ added in v0.4.1
func (x *GetTSDataResponse) GetTotal() int32
func (*GetTSDataResponse) ProtoMessage ¶ added in v0.4.1
func (*GetTSDataResponse) ProtoMessage()
func (*GetTSDataResponse) ProtoReflect ¶ added in v0.4.1
func (x *GetTSDataResponse) ProtoReflect() protoreflect.Message
func (*GetTSDataResponse) Reset ¶ added in v0.4.1
func (x *GetTSDataResponse) Reset()
func (*GetTSDataResponse) String ¶ added in v0.4.1
func (x *GetTSDataResponse) String() string
type HealthRequest ¶ added in v0.4.1
type HealthRequest struct {
// contains filtered or unexported fields
}
func (*HealthRequest) Descriptor
deprecated
added in
v0.4.1
func (*HealthRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.
func (*HealthRequest) ProtoMessage ¶ added in v0.4.1
func (*HealthRequest) ProtoMessage()
func (*HealthRequest) ProtoReflect ¶ added in v0.4.1
func (x *HealthRequest) ProtoReflect() protoreflect.Message
func (*HealthRequest) Reset ¶ added in v0.4.1
func (x *HealthRequest) Reset()
func (*HealthRequest) String ¶ added in v0.4.1
func (x *HealthRequest) String() string
type HealthResponse ¶ added in v0.4.1
type HealthResponse struct {
// contains filtered or unexported fields
}
func (*HealthResponse) Descriptor
deprecated
added in
v0.4.1
func (*HealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.
func (*HealthResponse) ProtoMessage ¶ added in v0.4.1
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) ProtoReflect ¶ added in v0.4.1
func (x *HealthResponse) ProtoReflect() protoreflect.Message
func (*HealthResponse) Reset ¶ added in v0.4.1
func (x *HealthResponse) Reset()
func (*HealthResponse) String ¶ added in v0.4.1
func (x *HealthResponse) String() string
type IndexObject ¶
type IndexObject struct { Obj *_struct.Value `protobuf:"bytes,1,opt,name=obj,proto3" json:"obj,omitempty"` // contains filtered or unexported fields }
func (*IndexObject) Descriptor
deprecated
func (*IndexObject) Descriptor() ([]byte, []int)
Deprecated: Use IndexObject.ProtoReflect.Descriptor instead.
func (*IndexObject) GetObj ¶
func (x *IndexObject) GetObj() *_struct.Value
func (*IndexObject) ProtoMessage ¶
func (*IndexObject) ProtoMessage()
func (*IndexObject) ProtoReflect ¶
func (x *IndexObject) ProtoReflect() protoreflect.Message
func (*IndexObject) Reset ¶
func (x *IndexObject) Reset()
func (*IndexObject) String ¶
func (x *IndexObject) String() string
type IndexResponse ¶
type IndexResponse struct { Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*IndexResponse) Descriptor
deprecated
func (*IndexResponse) Descriptor() ([]byte, []int)
Deprecated: Use IndexResponse.ProtoReflect.Descriptor instead.
func (*IndexResponse) GetStatus ¶
func (x *IndexResponse) GetStatus() string
func (*IndexResponse) ProtoMessage ¶
func (*IndexResponse) ProtoMessage()
func (*IndexResponse) ProtoReflect ¶
func (x *IndexResponse) ProtoReflect() protoreflect.Message
func (*IndexResponse) Reset ¶
func (x *IndexResponse) Reset()
func (*IndexResponse) String ¶
func (x *IndexResponse) String() string
type ListEntityRequest ¶
type ListEntityRequest struct { Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Query string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Condition []*SearchCondition `protobuf:"bytes,6,rep,name=condition,proto3" json:"condition,omitempty"` PageNum int32 `protobuf:"varint,7,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"` PageSize int32 `protobuf:"varint,8,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` OrderBy string `protobuf:"bytes,9,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` IsDescending bool `protobuf:"varint,10,opt,name=is_descending,json=isDescending,proto3" json:"is_descending,omitempty"` // contains filtered or unexported fields }
List Entity Request.
func (*ListEntityRequest) Descriptor
deprecated
func (*ListEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEntityRequest.ProtoReflect.Descriptor instead.
func (*ListEntityRequest) GetCondition ¶
func (x *ListEntityRequest) GetCondition() []*SearchCondition
func (*ListEntityRequest) GetIsDescending ¶ added in v0.4.1
func (x *ListEntityRequest) GetIsDescending() bool
func (*ListEntityRequest) GetOrderBy ¶ added in v0.4.1
func (x *ListEntityRequest) GetOrderBy() string
func (*ListEntityRequest) GetOwner ¶
func (x *ListEntityRequest) GetOwner() string
func (*ListEntityRequest) GetPageNum ¶ added in v0.4.1
func (x *ListEntityRequest) GetPageNum() int32
func (*ListEntityRequest) GetPageSize ¶ added in v0.4.1
func (x *ListEntityRequest) GetPageSize() int32
func (*ListEntityRequest) GetQuery ¶
func (x *ListEntityRequest) GetQuery() string
func (*ListEntityRequest) GetSource ¶
func (x *ListEntityRequest) GetSource() string
func (*ListEntityRequest) ProtoMessage ¶
func (*ListEntityRequest) ProtoMessage()
func (*ListEntityRequest) ProtoReflect ¶
func (x *ListEntityRequest) ProtoReflect() protoreflect.Message
func (*ListEntityRequest) Reset ¶
func (x *ListEntityRequest) Reset()
func (*ListEntityRequest) String ¶
func (x *ListEntityRequest) String() string
type ListEntityResponse ¶
type ListEntityResponse struct { Total int32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` PageNum int32 `protobuf:"varint,2,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"` PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Items []*EntityResponse `protobuf:"bytes,5,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
List Entity Response.
func (*ListEntityResponse) Descriptor
deprecated
func (*ListEntityResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEntityResponse.ProtoReflect.Descriptor instead.
func (*ListEntityResponse) GetItems ¶
func (x *ListEntityResponse) GetItems() []*EntityResponse
func (*ListEntityResponse) GetPageNum ¶ added in v0.4.1
func (x *ListEntityResponse) GetPageNum() int32
func (*ListEntityResponse) GetPageSize ¶ added in v0.4.1
func (x *ListEntityResponse) GetPageSize() int32
func (*ListEntityResponse) GetTotal ¶
func (x *ListEntityResponse) GetTotal() int32
func (*ListEntityResponse) ProtoMessage ¶
func (*ListEntityResponse) ProtoMessage()
func (*ListEntityResponse) ProtoReflect ¶
func (x *ListEntityResponse) ProtoReflect() protoreflect.Message
func (*ListEntityResponse) Reset ¶
func (x *ListEntityResponse) Reset()
func (*ListEntityResponse) String ¶
func (x *ListEntityResponse) String() string
type ListMapperRequest ¶ added in v0.4.1
type ListMapperRequest struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` EntityId string `protobuf:"bytes,4,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` // contains filtered or unexported fields }
List Mapper Request.
func (*ListMapperRequest) Descriptor
deprecated
added in
v0.4.1
func (*ListMapperRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMapperRequest.ProtoReflect.Descriptor instead.
func (*ListMapperRequest) GetEntityId ¶ added in v0.4.1
func (x *ListMapperRequest) GetEntityId() string
func (*ListMapperRequest) GetOwner ¶ added in v0.4.1
func (x *ListMapperRequest) GetOwner() string
func (*ListMapperRequest) GetSource ¶ added in v0.4.1
func (x *ListMapperRequest) GetSource() string
func (*ListMapperRequest) GetType ¶ added in v0.4.1
func (x *ListMapperRequest) GetType() string
func (*ListMapperRequest) ProtoMessage ¶ added in v0.4.1
func (*ListMapperRequest) ProtoMessage()
func (*ListMapperRequest) ProtoReflect ¶ added in v0.4.1
func (x *ListMapperRequest) ProtoReflect() protoreflect.Message
func (*ListMapperRequest) Reset ¶ added in v0.4.1
func (x *ListMapperRequest) Reset()
func (*ListMapperRequest) String ¶ added in v0.4.1
func (x *ListMapperRequest) String() string
type ListMapperResponse ¶ added in v0.4.1
type ListMapperResponse struct { Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` Mappers []*Mapper `protobuf:"bytes,6,rep,name=mappers,proto3" json:"mappers,omitempty"` // contains filtered or unexported fields }
List Mapper Response.
func (*ListMapperResponse) Descriptor
deprecated
added in
v0.4.1
func (*ListMapperResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMapperResponse.ProtoReflect.Descriptor instead.
func (*ListMapperResponse) GetEntityId ¶ added in v0.4.1
func (x *ListMapperResponse) GetEntityId() string
func (*ListMapperResponse) GetMappers ¶ added in v0.4.1
func (x *ListMapperResponse) GetMappers() []*Mapper
func (*ListMapperResponse) GetOwner ¶ added in v0.4.1
func (x *ListMapperResponse) GetOwner() string
func (*ListMapperResponse) GetSource ¶ added in v0.4.1
func (x *ListMapperResponse) GetSource() string
func (*ListMapperResponse) GetType ¶ added in v0.4.1
func (x *ListMapperResponse) GetType() string
func (*ListMapperResponse) ProtoMessage ¶ added in v0.4.1
func (*ListMapperResponse) ProtoMessage()
func (*ListMapperResponse) ProtoReflect ¶ added in v0.4.1
func (x *ListMapperResponse) ProtoReflect() protoreflect.Message
func (*ListMapperResponse) Reset ¶ added in v0.4.1
func (x *ListMapperResponse) Reset()
func (*ListMapperResponse) String ¶ added in v0.4.1
func (x *ListMapperResponse) String() string
type ListSubscriptionRequest ¶
type ListSubscriptionRequest struct { Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*ListSubscriptionRequest) Descriptor
deprecated
func (*ListSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*ListSubscriptionRequest) GetOwner ¶
func (x *ListSubscriptionRequest) GetOwner() string
func (*ListSubscriptionRequest) GetSource ¶
func (x *ListSubscriptionRequest) GetSource() string
func (*ListSubscriptionRequest) ProtoMessage ¶
func (*ListSubscriptionRequest) ProtoMessage()
func (*ListSubscriptionRequest) ProtoReflect ¶
func (x *ListSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*ListSubscriptionRequest) Reset ¶
func (x *ListSubscriptionRequest) Reset()
func (*ListSubscriptionRequest) String ¶
func (x *ListSubscriptionRequest) String() string
type ListSubscriptionResponse ¶
type ListSubscriptionResponse struct { Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Items []*SubscriptionResponse `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*ListSubscriptionResponse) Descriptor
deprecated
func (*ListSubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscriptionResponse.ProtoReflect.Descriptor instead.
func (*ListSubscriptionResponse) GetCount ¶
func (x *ListSubscriptionResponse) GetCount() int32
func (*ListSubscriptionResponse) GetItems ¶
func (x *ListSubscriptionResponse) GetItems() []*SubscriptionResponse
func (*ListSubscriptionResponse) ProtoMessage ¶
func (*ListSubscriptionResponse) ProtoMessage()
func (*ListSubscriptionResponse) ProtoReflect ¶
func (x *ListSubscriptionResponse) ProtoReflect() protoreflect.Message
func (*ListSubscriptionResponse) Reset ¶
func (x *ListSubscriptionResponse) Reset()
func (*ListSubscriptionResponse) String ¶
func (x *ListSubscriptionResponse) String() string
type Mapper ¶ added in v0.4.1
type Mapper struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Tql string `protobuf:"bytes,3,opt,name=tql,proto3" json:"tql,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // contains filtered or unexported fields }
func (*Mapper) Descriptor
deprecated
added in
v0.4.1
func (*Mapper) GetDescription ¶ added in v0.4.1
func (*Mapper) ProtoMessage ¶ added in v0.4.1
func (*Mapper) ProtoMessage()
func (*Mapper) ProtoReflect ¶ added in v0.4.1
func (x *Mapper) ProtoReflect() protoreflect.Message
type Metadata ¶ added in v0.4.1
type Metadata struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Specversion string `protobuf:"bytes,2,opt,name=specversion,proto3" json:"specversion,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` Datacontenttype string `protobuf:"bytes,5,opt,name=datacontenttype,proto3" json:"datacontenttype,omitempty"` Subject string `protobuf:"bytes,9,opt,name=subject,proto3" json:"subject,omitempty"` Topic string `protobuf:"bytes,10,opt,name=topic,proto3" json:"topic,omitempty"` Pubsubname string `protobuf:"bytes,11,opt,name=pubsubname,proto3" json:"pubsubname,omitempty"` // contains filtered or unexported fields }
func (*Metadata) Descriptor
deprecated
added in
v0.4.1
func (*Metadata) GetDatacontenttype ¶ added in v0.4.1
func (*Metadata) GetPubsubname ¶ added in v0.4.1
func (*Metadata) GetSpecversion ¶ added in v0.4.1
func (*Metadata) GetSubject ¶ added in v0.4.1
func (*Metadata) ProtoMessage ¶ added in v0.4.1
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶ added in v0.4.1
func (x *Metadata) ProtoReflect() protoreflect.Message
type Pager ¶
type Pager struct { Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` Offset int32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Sort string `protobuf:"bytes,3,opt,name=sort,proto3" json:"sort,omitempty"` Reverse bool `protobuf:"varint,4,opt,name=reverse,proto3" json:"reverse,omitempty"` // contains filtered or unexported fields }
func (*Pager) Descriptor
deprecated
func (*Pager) GetReverse ¶
func (*Pager) ProtoMessage ¶
func (*Pager) ProtoMessage()
func (*Pager) ProtoReflect ¶
func (x *Pager) ProtoReflect() protoreflect.Message
type PatchData ¶ added in v0.2.1
type PatchData struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"` Value *_struct.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*PatchData) Descriptor
deprecated
added in
v0.2.1
func (*PatchData) GetOperator ¶ added in v0.2.1
func (*PatchData) ProtoMessage ¶ added in v0.2.1
func (*PatchData) ProtoMessage()
func (*PatchData) ProtoReflect ¶ added in v0.2.1
func (x *PatchData) ProtoReflect() protoreflect.Message
type PatchDatas ¶ added in v0.2.1
type PatchDatas struct { Properties []*PatchData `protobuf:"bytes,1,rep,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
func (*PatchDatas) Descriptor
deprecated
added in
v0.2.1
func (*PatchDatas) Descriptor() ([]byte, []int)
Deprecated: Use PatchDatas.ProtoReflect.Descriptor instead.
func (*PatchDatas) GetProperties ¶ added in v0.2.1
func (x *PatchDatas) GetProperties() []*PatchData
func (*PatchDatas) ProtoMessage ¶ added in v0.2.1
func (*PatchDatas) ProtoMessage()
func (*PatchDatas) ProtoReflect ¶ added in v0.2.1
func (x *PatchDatas) ProtoReflect() protoreflect.Message
func (*PatchDatas) Reset ¶ added in v0.2.1
func (x *PatchDatas) Reset()
func (*PatchDatas) String ¶ added in v0.2.1
func (x *PatchDatas) String() string
type PatchEntityConfigsRequest ¶ added in v0.4.1
type PatchEntityConfigsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` Configs *_struct.Value `protobuf:"bytes,5,opt,name=configs,proto3" json:"configs,omitempty"` // contains filtered or unexported fields }
Patch Entity Configs Request.
func (*PatchEntityConfigsRequest) Descriptor
deprecated
added in
v0.4.1
func (*PatchEntityConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PatchEntityConfigsRequest.ProtoReflect.Descriptor instead.
func (*PatchEntityConfigsRequest) GetConfigs ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) GetConfigs() *_struct.Value
func (*PatchEntityConfigsRequest) GetId ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) GetId() string
func (*PatchEntityConfigsRequest) GetOwner ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) GetOwner() string
func (*PatchEntityConfigsRequest) GetSource ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) GetSource() string
func (*PatchEntityConfigsRequest) GetType ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) GetType() string
func (*PatchEntityConfigsRequest) ProtoMessage ¶ added in v0.4.1
func (*PatchEntityConfigsRequest) ProtoMessage()
func (*PatchEntityConfigsRequest) ProtoReflect ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) ProtoReflect() protoreflect.Message
func (*PatchEntityConfigsRequest) Reset ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) Reset()
func (*PatchEntityConfigsRequest) String ¶ added in v0.4.1
func (x *PatchEntityConfigsRequest) String() string
type PatchEntityPropsRequest ¶ added in v0.4.1
type PatchEntityPropsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` Properties *_struct.Value `protobuf:"bytes,6,opt,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
Patch Entity Properties Request.
func (*PatchEntityPropsRequest) Descriptor
deprecated
added in
v0.4.1
func (*PatchEntityPropsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PatchEntityPropsRequest.ProtoReflect.Descriptor instead.
func (*PatchEntityPropsRequest) GetId ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) GetId() string
func (*PatchEntityPropsRequest) GetOwner ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) GetOwner() string
func (*PatchEntityPropsRequest) GetProperties ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) GetProperties() *_struct.Value
func (*PatchEntityPropsRequest) GetSource ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) GetSource() string
func (*PatchEntityPropsRequest) GetType ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) GetType() string
func (*PatchEntityPropsRequest) ProtoMessage ¶ added in v0.4.1
func (*PatchEntityPropsRequest) ProtoMessage()
func (*PatchEntityPropsRequest) ProtoReflect ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) ProtoReflect() protoreflect.Message
func (*PatchEntityPropsRequest) Reset ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) Reset()
func (*PatchEntityPropsRequest) String ¶ added in v0.4.1
func (x *PatchEntityPropsRequest) String() string
type ProbeClient ¶ added in v0.4.1
type ProbeClient interface {
Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
}
ProbeClient is the client API for Probe 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 NewProbeClient ¶ added in v0.4.1
func NewProbeClient(cc grpc.ClientConnInterface) ProbeClient
type ProbeHTTPHandler ¶ added in v0.4.1
type ProbeHTTPHandler struct {
// contains filtered or unexported fields
}
func (*ProbeHTTPHandler) Health ¶ added in v0.4.1
func (h *ProbeHTTPHandler) Health(req *go_restful.Request, resp *go_restful.Response)
type ProbeHTTPServer ¶ added in v0.4.1
type ProbeHTTPServer interface {
Health(context.Context, *HealthRequest) (*HealthResponse, error)
}
type ProbeServer ¶ added in v0.4.1
type ProbeServer interface { Health(context.Context, *HealthRequest) (*HealthResponse, error) // contains filtered or unexported methods }
ProbeServer is the server API for Probe service. All implementations must embed UnimplementedProbeServer for forward compatibility
type ProxyClient ¶ added in v0.4.1
type ProxyClient interface {
Respond(ctx context.Context, in *RespondRequest, opts ...grpc.CallOption) (*RespondResponse, error)
}
ProxyClient is the client API for Proxy 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 NewProxyClient ¶ added in v0.4.1
func NewProxyClient(cc grpc.ClientConnInterface) ProxyClient
type ProxyHTTPHandler ¶ added in v0.4.1
type ProxyHTTPHandler struct {
// contains filtered or unexported fields
}
func (*ProxyHTTPHandler) Respond ¶ added in v0.4.1
func (h *ProxyHTTPHandler) Respond(req *go_restful.Request, resp *go_restful.Response)
type ProxyHTTPServer ¶ added in v0.4.1
type ProxyHTTPServer interface {
Respond(context.Context, *RespondRequest) (*RespondResponse, error)
}
type ProxyServer ¶ added in v0.4.1
type ProxyServer interface { Respond(context.Context, *RespondRequest) (*RespondResponse, error) // contains filtered or unexported methods }
ProxyServer is the server API for Proxy service. All implementations must embed UnimplementedProxyServer for forward compatibility
type RemoveEntityConfigsRequest ¶ added in v0.4.1
type RemoveEntityConfigsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` PropertyKeys string `protobuf:"bytes,5,opt,name=property_keys,json=propertyKeys,proto3" json:"property_keys,omitempty"` // contains filtered or unexported fields }
Remove Entity Configs Request.
func (*RemoveEntityConfigsRequest) Descriptor
deprecated
added in
v0.4.1
func (*RemoveEntityConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveEntityConfigsRequest.ProtoReflect.Descriptor instead.
func (*RemoveEntityConfigsRequest) GetId ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) GetId() string
func (*RemoveEntityConfigsRequest) GetOwner ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) GetOwner() string
func (*RemoveEntityConfigsRequest) GetPropertyKeys ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) GetPropertyKeys() string
func (*RemoveEntityConfigsRequest) GetSource ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) GetSource() string
func (*RemoveEntityConfigsRequest) GetType ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) GetType() string
func (*RemoveEntityConfigsRequest) ProtoMessage ¶ added in v0.4.1
func (*RemoveEntityConfigsRequest) ProtoMessage()
func (*RemoveEntityConfigsRequest) ProtoReflect ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) ProtoReflect() protoreflect.Message
func (*RemoveEntityConfigsRequest) Reset ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) Reset()
func (*RemoveEntityConfigsRequest) String ¶ added in v0.4.1
func (x *RemoveEntityConfigsRequest) String() string
type RemoveEntityPropsRequest ¶ added in v0.4.1
type RemoveEntityPropsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` PropertyKeys string `protobuf:"bytes,5,opt,name=property_keys,json=propertyKeys,proto3" json:"property_keys,omitempty"` // contains filtered or unexported fields }
Remove Entity Properties Request.
func (*RemoveEntityPropsRequest) Descriptor
deprecated
added in
v0.4.1
func (*RemoveEntityPropsRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveEntityPropsRequest.ProtoReflect.Descriptor instead.
func (*RemoveEntityPropsRequest) GetId ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) GetId() string
func (*RemoveEntityPropsRequest) GetOwner ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) GetOwner() string
func (*RemoveEntityPropsRequest) GetPropertyKeys ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) GetPropertyKeys() string
func (*RemoveEntityPropsRequest) GetSource ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) GetSource() string
func (*RemoveEntityPropsRequest) GetType ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) GetType() string
func (*RemoveEntityPropsRequest) ProtoMessage ¶ added in v0.4.1
func (*RemoveEntityPropsRequest) ProtoMessage()
func (*RemoveEntityPropsRequest) ProtoReflect ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) ProtoReflect() protoreflect.Message
func (*RemoveEntityPropsRequest) Reset ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) Reset()
func (*RemoveEntityPropsRequest) String ¶ added in v0.4.1
func (x *RemoveEntityPropsRequest) String() string
type RemoveMapperRequest ¶ added in v0.3.1
type RemoveMapperRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` // contains filtered or unexported fields }
Remove Mapper Request.
func (*RemoveMapperRequest) Descriptor
deprecated
added in
v0.3.1
func (*RemoveMapperRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveMapperRequest.ProtoReflect.Descriptor instead.
func (*RemoveMapperRequest) GetEntityId ¶ added in v0.4.1
func (x *RemoveMapperRequest) GetEntityId() string
func (*RemoveMapperRequest) GetId ¶ added in v0.3.1
func (x *RemoveMapperRequest) GetId() string
func (*RemoveMapperRequest) GetOwner ¶ added in v0.3.1
func (x *RemoveMapperRequest) GetOwner() string
func (*RemoveMapperRequest) GetSource ¶ added in v0.3.1
func (x *RemoveMapperRequest) GetSource() string
func (*RemoveMapperRequest) GetType ¶ added in v0.3.1
func (x *RemoveMapperRequest) GetType() string
func (*RemoveMapperRequest) ProtoMessage ¶ added in v0.3.1
func (*RemoveMapperRequest) ProtoMessage()
func (*RemoveMapperRequest) ProtoReflect ¶ added in v0.3.1
func (x *RemoveMapperRequest) ProtoReflect() protoreflect.Message
func (*RemoveMapperRequest) Reset ¶ added in v0.3.1
func (x *RemoveMapperRequest) Reset()
func (*RemoveMapperRequest) String ¶ added in v0.3.1
func (x *RemoveMapperRequest) String() string
type RemoveMapperResponse ¶ added in v0.4.1
type RemoveMapperResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` // contains filtered or unexported fields }
Remove Mapper Response.
func (*RemoveMapperResponse) Descriptor
deprecated
added in
v0.4.1
func (*RemoveMapperResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveMapperResponse.ProtoReflect.Descriptor instead.
func (*RemoveMapperResponse) GetEntityId ¶ added in v0.4.1
func (x *RemoveMapperResponse) GetEntityId() string
func (*RemoveMapperResponse) GetId ¶ added in v0.4.1
func (x *RemoveMapperResponse) GetId() string
func (*RemoveMapperResponse) GetOwner ¶ added in v0.4.1
func (x *RemoveMapperResponse) GetOwner() string
func (*RemoveMapperResponse) GetSource ¶ added in v0.4.1
func (x *RemoveMapperResponse) GetSource() string
func (*RemoveMapperResponse) GetType ¶ added in v0.4.1
func (x *RemoveMapperResponse) GetType() string
func (*RemoveMapperResponse) ProtoMessage ¶ added in v0.4.1
func (*RemoveMapperResponse) ProtoMessage()
func (*RemoveMapperResponse) ProtoReflect ¶ added in v0.4.1
func (x *RemoveMapperResponse) ProtoReflect() protoreflect.Message
func (*RemoveMapperResponse) Reset ¶ added in v0.4.1
func (x *RemoveMapperResponse) Reset()
func (*RemoveMapperResponse) String ¶ added in v0.4.1
func (x *RemoveMapperResponse) String() string
type RespondRequest ¶ added in v0.4.1
type RespondRequest struct { Metadata map[string]string `` /* 157-byte string literal not displayed */ Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*RespondRequest) Descriptor
deprecated
added in
v0.4.1
func (*RespondRequest) Descriptor() ([]byte, []int)
Deprecated: Use RespondRequest.ProtoReflect.Descriptor instead.
func (*RespondRequest) GetData ¶ added in v0.4.1
func (x *RespondRequest) GetData() []byte
func (*RespondRequest) GetMetadata ¶ added in v0.4.1
func (x *RespondRequest) GetMetadata() map[string]string
func (*RespondRequest) ProtoMessage ¶ added in v0.4.1
func (*RespondRequest) ProtoMessage()
func (*RespondRequest) ProtoReflect ¶ added in v0.4.1
func (x *RespondRequest) ProtoReflect() protoreflect.Message
func (*RespondRequest) Reset ¶ added in v0.4.1
func (x *RespondRequest) Reset()
func (*RespondRequest) String ¶ added in v0.4.1
func (x *RespondRequest) String() string
type RespondResponse ¶ added in v0.4.1
type RespondResponse struct {
// contains filtered or unexported fields
}
func (*RespondResponse) Descriptor
deprecated
added in
v0.4.1
func (*RespondResponse) Descriptor() ([]byte, []int)
Deprecated: Use RespondResponse.ProtoReflect.Descriptor instead.
func (*RespondResponse) ProtoMessage ¶ added in v0.4.1
func (*RespondResponse) ProtoMessage()
func (*RespondResponse) ProtoReflect ¶ added in v0.4.1
func (x *RespondResponse) ProtoReflect() protoreflect.Message
func (*RespondResponse) Reset ¶ added in v0.4.1
func (x *RespondResponse) Reset()
func (*RespondResponse) String ¶ added in v0.4.1
func (x *RespondResponse) String() string
type SearchClient ¶
type SearchClient interface { Index(ctx context.Context, in *IndexObject, opts ...grpc.CallOption) (*IndexResponse, error) Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error) DeleteByID(ctx context.Context, in *DeleteByIDRequest, opts ...grpc.CallOption) (*DeleteByIDResponse, error) }
SearchClient is the client API for Search 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 NewSearchClient ¶
func NewSearchClient(cc grpc.ClientConnInterface) SearchClient
type SearchCondition ¶
type SearchCondition struct { Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"` Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"` Value *_struct.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*SearchCondition) Descriptor
deprecated
func (*SearchCondition) Descriptor() ([]byte, []int)
Deprecated: Use SearchCondition.ProtoReflect.Descriptor instead.
func (*SearchCondition) GetField ¶
func (x *SearchCondition) GetField() string
func (*SearchCondition) GetOperator ¶
func (x *SearchCondition) GetOperator() string
func (*SearchCondition) GetValue ¶
func (x *SearchCondition) GetValue() *_struct.Value
func (*SearchCondition) ProtoMessage ¶
func (*SearchCondition) ProtoMessage()
func (*SearchCondition) ProtoReflect ¶
func (x *SearchCondition) ProtoReflect() protoreflect.Message
func (*SearchCondition) Reset ¶
func (x *SearchCondition) Reset()
func (*SearchCondition) String ¶
func (x *SearchCondition) String() string
type SearchHTTPHandler ¶
type SearchHTTPHandler struct {
// contains filtered or unexported fields
}
func (*SearchHTTPHandler) DeleteByID ¶ added in v0.3.0
func (h *SearchHTTPHandler) DeleteByID(req *go_restful.Request, resp *go_restful.Response)
func (*SearchHTTPHandler) Index ¶
func (h *SearchHTTPHandler) Index(req *go_restful.Request, resp *go_restful.Response)
func (*SearchHTTPHandler) Search ¶
func (h *SearchHTTPHandler) Search(req *go_restful.Request, resp *go_restful.Response)
type SearchHTTPServer ¶
type SearchHTTPServer interface { DeleteByID(context.Context, *DeleteByIDRequest) (*DeleteByIDResponse, error) Index(context.Context, *IndexObject) (*IndexResponse, error) Search(context.Context, *SearchRequest) (*SearchResponse, error) }
type SearchRequest ¶
type SearchRequest struct { Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` Query string `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` Condition []*SearchCondition `protobuf:"bytes,5,rep,name=condition,proto3" json:"condition,omitempty"` PageNum int32 `protobuf:"varint,7,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"` PageSize int32 `protobuf:"varint,8,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` OrderBy string `protobuf:"bytes,9,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` IsDescending bool `protobuf:"varint,10,opt,name=is_descending,json=isDescending,proto3" json:"is_descending,omitempty"` // contains filtered or unexported fields }
func (*SearchRequest) Descriptor
deprecated
func (*SearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
func (*SearchRequest) GetCondition ¶
func (x *SearchRequest) GetCondition() []*SearchCondition
func (*SearchRequest) GetIsDescending ¶ added in v0.4.1
func (x *SearchRequest) GetIsDescending() bool
func (*SearchRequest) GetOrderBy ¶ added in v0.4.1
func (x *SearchRequest) GetOrderBy() string
func (*SearchRequest) GetOwner ¶ added in v0.3.0
func (x *SearchRequest) GetOwner() string
func (*SearchRequest) GetPageNum ¶ added in v0.4.1
func (x *SearchRequest) GetPageNum() int32
func (*SearchRequest) GetPageSize ¶ added in v0.4.1
func (x *SearchRequest) GetPageSize() int32
func (*SearchRequest) GetQuery ¶
func (x *SearchRequest) GetQuery() string
func (*SearchRequest) GetSource ¶ added in v0.3.0
func (x *SearchRequest) GetSource() string
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) ProtoReflect ¶
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (*SearchRequest) Reset ¶
func (x *SearchRequest) Reset()
func (*SearchRequest) String ¶
func (x *SearchRequest) String() string
type SearchResponse ¶
type SearchResponse struct { Total int32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` PageNum int32 `protobuf:"varint,2,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"` PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Items []*_struct.Value `protobuf:"bytes,5,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*SearchResponse) Descriptor
deprecated
func (*SearchResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.
func (*SearchResponse) GetItems ¶
func (x *SearchResponse) GetItems() []*_struct.Value
func (*SearchResponse) GetPageNum ¶ added in v0.4.1
func (x *SearchResponse) GetPageNum() int32
func (*SearchResponse) GetPageSize ¶ added in v0.4.1
func (x *SearchResponse) GetPageSize() int32
func (*SearchResponse) GetTotal ¶
func (x *SearchResponse) GetTotal() int32
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) ProtoReflect ¶
func (x *SearchResponse) ProtoReflect() protoreflect.Message
func (*SearchResponse) Reset ¶
func (x *SearchResponse) Reset()
func (*SearchResponse) String ¶
func (x *SearchResponse) String() string
type SearchServer ¶
type SearchServer interface { Index(context.Context, *IndexObject) (*IndexResponse, error) Search(context.Context, *SearchRequest) (*SearchResponse, error) DeleteByID(context.Context, *DeleteByIDRequest) (*DeleteByIDResponse, error) // contains filtered or unexported methods }
SearchServer is the server API for Search service. All implementations must embed UnimplementedSearchServer for forward compatibility
type SubscriptionClient ¶
type SubscriptionClient interface { CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest, opts ...grpc.CallOption) (*SubscriptionResponse, error) UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*SubscriptionResponse, error) DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*DeleteSubscriptionResponse, error) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*SubscriptionResponse, error) ListSubscription(ctx context.Context, in *ListSubscriptionRequest, opts ...grpc.CallOption) (*ListSubscriptionResponse, error) }
SubscriptionClient is the client API for Subscription 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 NewSubscriptionClient ¶
func NewSubscriptionClient(cc grpc.ClientConnInterface) SubscriptionClient
type SubscriptionHTTPHandler ¶
type SubscriptionHTTPHandler struct {
// contains filtered or unexported fields
}
func (*SubscriptionHTTPHandler) CreateSubscription ¶
func (h *SubscriptionHTTPHandler) CreateSubscription(req *go_restful.Request, resp *go_restful.Response)
func (*SubscriptionHTTPHandler) DeleteSubscription ¶
func (h *SubscriptionHTTPHandler) DeleteSubscription(req *go_restful.Request, resp *go_restful.Response)
func (*SubscriptionHTTPHandler) GetSubscription ¶
func (h *SubscriptionHTTPHandler) GetSubscription(req *go_restful.Request, resp *go_restful.Response)
func (*SubscriptionHTTPHandler) ListSubscription ¶
func (h *SubscriptionHTTPHandler) ListSubscription(req *go_restful.Request, resp *go_restful.Response)
func (*SubscriptionHTTPHandler) UpdateSubscription ¶
func (h *SubscriptionHTTPHandler) UpdateSubscription(req *go_restful.Request, resp *go_restful.Response)
type SubscriptionHTTPServer ¶
type SubscriptionHTTPServer interface { CreateSubscription(context.Context, *CreateSubscriptionRequest) (*SubscriptionResponse, error) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error) GetSubscription(context.Context, *GetSubscriptionRequest) (*SubscriptionResponse, error) ListSubscription(context.Context, *ListSubscriptionRequest) (*ListSubscriptionResponse, error) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*SubscriptionResponse, error) }
type SubscriptionObject ¶
type SubscriptionObject struct { Mode string `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"` Topic string `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"` PubsubName string `protobuf:"bytes,6,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"` // contains filtered or unexported fields }
func (*SubscriptionObject) Descriptor
deprecated
func (*SubscriptionObject) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionObject.ProtoReflect.Descriptor instead.
func (*SubscriptionObject) GetFilter ¶
func (x *SubscriptionObject) GetFilter() string
func (*SubscriptionObject) GetMode ¶
func (x *SubscriptionObject) GetMode() string
func (*SubscriptionObject) GetPubsubName ¶
func (x *SubscriptionObject) GetPubsubName() string
func (*SubscriptionObject) GetSource ¶
func (x *SubscriptionObject) GetSource() string
func (*SubscriptionObject) GetTarget ¶
func (x *SubscriptionObject) GetTarget() string
func (*SubscriptionObject) GetTopic ¶
func (x *SubscriptionObject) GetTopic() string
func (*SubscriptionObject) ProtoMessage ¶
func (*SubscriptionObject) ProtoMessage()
func (*SubscriptionObject) ProtoReflect ¶
func (x *SubscriptionObject) ProtoReflect() protoreflect.Message
func (*SubscriptionObject) Reset ¶
func (x *SubscriptionObject) Reset()
func (*SubscriptionObject) String ¶
func (x *SubscriptionObject) String() string
type SubscriptionResponse ¶
type SubscriptionResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Subscription *SubscriptionObject `protobuf:"bytes,5,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
func (*SubscriptionResponse) Descriptor
deprecated
func (*SubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionResponse.ProtoReflect.Descriptor instead.
func (*SubscriptionResponse) GetId ¶
func (x *SubscriptionResponse) GetId() string
func (*SubscriptionResponse) GetOwner ¶
func (x *SubscriptionResponse) GetOwner() string
func (*SubscriptionResponse) GetSource ¶
func (x *SubscriptionResponse) GetSource() string
func (*SubscriptionResponse) GetSubscription ¶
func (x *SubscriptionResponse) GetSubscription() *SubscriptionObject
func (*SubscriptionResponse) ProtoMessage ¶
func (*SubscriptionResponse) ProtoMessage()
func (*SubscriptionResponse) ProtoReflect ¶
func (x *SubscriptionResponse) ProtoReflect() protoreflect.Message
func (*SubscriptionResponse) Reset ¶
func (x *SubscriptionResponse) Reset()
func (*SubscriptionResponse) String ¶
func (x *SubscriptionResponse) String() string
type SubscriptionServer ¶
type SubscriptionServer interface { CreateSubscription(context.Context, *CreateSubscriptionRequest) (*SubscriptionResponse, error) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*SubscriptionResponse, error) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error) GetSubscription(context.Context, *GetSubscriptionRequest) (*SubscriptionResponse, error) ListSubscription(context.Context, *ListSubscriptionRequest) (*ListSubscriptionResponse, error) // contains filtered or unexported methods }
SubscriptionServer is the server API for Subscription service. All implementations must embed UnimplementedSubscriptionServer for forward compatibility
type TSClient ¶ added in v0.4.1
type TSClient interface { GetTSData(ctx context.Context, in *GetTSDataRequest, opts ...grpc.CallOption) (*GetTSDataResponse, error) DownloadTSData(ctx context.Context, in *DownloadTSDataRequest, opts ...grpc.CallOption) (*DownloadTSDataResponse, error) GetLatestEntities(ctx context.Context, in *GetLatestEntitiesRequest, opts ...grpc.CallOption) (*GetLatestEntitiesResponse, error) }
TSClient is the client API for TS 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 NewTSClient ¶ added in v0.4.1
func NewTSClient(cc grpc.ClientConnInterface) TSClient
type TSHTTPHandler ¶ added in v0.4.1
type TSHTTPHandler struct {
// contains filtered or unexported fields
}
func (*TSHTTPHandler) DownloadTSData ¶ added in v0.4.1
func (h *TSHTTPHandler) DownloadTSData(req *go_restful.Request, resp *go_restful.Response)
func (*TSHTTPHandler) GetLatestEntities ¶ added in v0.4.1
func (h *TSHTTPHandler) GetLatestEntities(req *go_restful.Request, resp *go_restful.Response)
func (*TSHTTPHandler) GetTSData ¶ added in v0.4.1
func (h *TSHTTPHandler) GetTSData(req *go_restful.Request, resp *go_restful.Response)
type TSHTTPServer ¶ added in v0.4.1
type TSHTTPServer interface { DownloadTSData(context.Context, *DownloadTSDataRequest) (*DownloadTSDataResponse, error) GetLatestEntities(context.Context, *GetLatestEntitiesRequest) (*GetLatestEntitiesResponse, error) GetTSData(context.Context, *GetTSDataRequest) (*GetTSDataResponse, error) }
type TSResponse ¶ added in v0.4.1
type TSResponse struct { Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"` Value map[string]float32 `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TSResponse) Descriptor
deprecated
added in
v0.4.1
func (*TSResponse) Descriptor() ([]byte, []int)
Deprecated: Use TSResponse.ProtoReflect.Descriptor instead.
func (*TSResponse) GetTime ¶ added in v0.4.1
func (x *TSResponse) GetTime() int64
func (*TSResponse) GetValue ¶ added in v0.4.1
func (x *TSResponse) GetValue() map[string]float32
func (*TSResponse) ProtoMessage ¶ added in v0.4.1
func (*TSResponse) ProtoMessage()
func (*TSResponse) ProtoReflect ¶ added in v0.4.1
func (x *TSResponse) ProtoReflect() protoreflect.Message
func (*TSResponse) Reset ¶ added in v0.4.1
func (x *TSResponse) Reset()
func (*TSResponse) String ¶ added in v0.4.1
func (x *TSResponse) String() string
type TSServer ¶ added in v0.4.1
type TSServer interface { GetTSData(context.Context, *GetTSDataRequest) (*GetTSDataResponse, error) DownloadTSData(context.Context, *DownloadTSDataRequest) (*DownloadTSDataResponse, error) GetLatestEntities(context.Context, *GetLatestEntitiesRequest) (*GetLatestEntitiesResponse, error) // contains filtered or unexported methods }
TSServer is the server API for TS service. All implementations must embed UnimplementedTSServer for forward compatibility
type TopicClient ¶
type TopicClient interface { TopicEventHandler(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*TopicEventResponse, error) TopicClusterEventHandler(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*TopicEventResponse, error) }
TopicClient is the client API for Topic 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 NewTopicClient ¶
func NewTopicClient(cc grpc.ClientConnInterface) TopicClient
type TopicEventRequest ¶
type TopicEventRequest struct { Meta *Metadata `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` Data *_struct.Value `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` DataBase64 string `protobuf:"bytes,7,opt,name=data_base64,json=dataBase64,proto3" json:"data_base64,omitempty"` RawData []byte `protobuf:"bytes,8,opt,name=raw_data,json=rawData,proto3" json:"raw_data,omitempty"` // contains filtered or unexported fields }
func (*TopicEventRequest) Descriptor
deprecated
func (*TopicEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use TopicEventRequest.ProtoReflect.Descriptor instead.
func (*TopicEventRequest) GetData ¶
func (x *TopicEventRequest) GetData() *_struct.Value
func (*TopicEventRequest) GetDataBase64 ¶
func (x *TopicEventRequest) GetDataBase64() string
func (*TopicEventRequest) GetMeta ¶ added in v0.4.1
func (x *TopicEventRequest) GetMeta() *Metadata
func (*TopicEventRequest) GetRawData ¶ added in v0.4.1
func (x *TopicEventRequest) GetRawData() []byte
func (*TopicEventRequest) ProtoMessage ¶
func (*TopicEventRequest) ProtoMessage()
func (*TopicEventRequest) ProtoReflect ¶
func (x *TopicEventRequest) ProtoReflect() protoreflect.Message
func (*TopicEventRequest) Reset ¶
func (x *TopicEventRequest) Reset()
func (*TopicEventRequest) String ¶
func (x *TopicEventRequest) String() string
type TopicEventResponse ¶
type TopicEventResponse struct { Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*TopicEventResponse) Descriptor
deprecated
func (*TopicEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use TopicEventResponse.ProtoReflect.Descriptor instead.
func (*TopicEventResponse) GetStatus ¶
func (x *TopicEventResponse) GetStatus() string
func (*TopicEventResponse) ProtoMessage ¶
func (*TopicEventResponse) ProtoMessage()
func (*TopicEventResponse) ProtoReflect ¶
func (x *TopicEventResponse) ProtoReflect() protoreflect.Message
func (*TopicEventResponse) Reset ¶
func (x *TopicEventResponse) Reset()
func (*TopicEventResponse) String ¶
func (x *TopicEventResponse) String() string
type TopicHTTPHandler ¶
type TopicHTTPHandler struct {
// contains filtered or unexported fields
}
func (*TopicHTTPHandler) TopicClusterEventHandler ¶ added in v0.4.1
func (h *TopicHTTPHandler) TopicClusterEventHandler(req *go_restful.Request, resp *go_restful.Response)
func (*TopicHTTPHandler) TopicEventHandler ¶
func (h *TopicHTTPHandler) TopicEventHandler(req *go_restful.Request, resp *go_restful.Response)
type TopicHTTPServer ¶
type TopicHTTPServer interface { TopicEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error) TopicClusterEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error) }
type TopicServer ¶
type TopicServer interface { TopicEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error) TopicClusterEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error) // contains filtered or unexported methods }
TopicServer is the server API for Topic service. All implementations must embed UnimplementedTopicServer for forward compatibility
type UnimplementedEntityServer ¶
type UnimplementedEntityServer struct { }
UnimplementedEntityServer must be embedded to have forward compatible implementations.
func (UnimplementedEntityServer) AppendMapper ¶
func (UnimplementedEntityServer) AppendMapper(context.Context, *AppendMapperRequest) (*AppendMapperResponse, error)
func (UnimplementedEntityServer) CreateEntity ¶
func (UnimplementedEntityServer) CreateEntity(context.Context, *CreateEntityRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) DeleteEntity ¶
func (UnimplementedEntityServer) DeleteEntity(context.Context, *DeleteEntityRequest) (*DeleteEntityResponse, error)
func (UnimplementedEntityServer) GetEntity ¶
func (UnimplementedEntityServer) GetEntity(context.Context, *GetEntityRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) GetEntityConfigs ¶ added in v0.4.1
func (UnimplementedEntityServer) GetEntityConfigs(context.Context, *GetEntityConfigsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) GetEntityProps ¶ added in v0.3.0
func (UnimplementedEntityServer) GetEntityProps(context.Context, *GetEntityPropsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) GetMapper ¶ added in v0.4.1
func (UnimplementedEntityServer) GetMapper(context.Context, *GetMapperRequest) (*GetMapperResponse, error)
func (UnimplementedEntityServer) ListEntity ¶
func (UnimplementedEntityServer) ListEntity(context.Context, *ListEntityRequest) (*ListEntityResponse, error)
func (UnimplementedEntityServer) ListMapper ¶ added in v0.4.1
func (UnimplementedEntityServer) ListMapper(context.Context, *ListMapperRequest) (*ListMapperResponse, error)
func (UnimplementedEntityServer) PatchEntityConfigs ¶ added in v0.4.1
func (UnimplementedEntityServer) PatchEntityConfigs(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) PatchEntityConfigsZ ¶ added in v0.4.1
func (UnimplementedEntityServer) PatchEntityConfigsZ(context.Context, *PatchEntityConfigsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) PatchEntityProps ¶ added in v0.4.1
func (UnimplementedEntityServer) PatchEntityProps(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) PatchEntityPropsZ ¶ added in v0.4.1
func (UnimplementedEntityServer) PatchEntityPropsZ(context.Context, *PatchEntityPropsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) RemoveEntityConfigs ¶ added in v0.4.1
func (UnimplementedEntityServer) RemoveEntityConfigs(context.Context, *RemoveEntityConfigsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) RemoveEntityProps ¶ added in v0.4.1
func (UnimplementedEntityServer) RemoveEntityProps(context.Context, *RemoveEntityPropsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) RemoveMapper ¶ added in v0.3.1
func (UnimplementedEntityServer) RemoveMapper(context.Context, *RemoveMapperRequest) (*RemoveMapperResponse, error)
func (UnimplementedEntityServer) UpdateEntity ¶
func (UnimplementedEntityServer) UpdateEntity(context.Context, *UpdateEntityRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) UpdateEntityConfigs ¶ added in v0.4.1
func (UnimplementedEntityServer) UpdateEntityConfigs(context.Context, *UpdateEntityConfigsRequest) (*EntityResponse, error)
func (UnimplementedEntityServer) UpdateEntityProps ¶ added in v0.4.1
func (UnimplementedEntityServer) UpdateEntityProps(context.Context, *UpdateEntityPropsRequest) (*EntityResponse, error)
type UnimplementedProbeServer ¶ added in v0.4.1
type UnimplementedProbeServer struct { }
UnimplementedProbeServer must be embedded to have forward compatible implementations.
func (UnimplementedProbeServer) Health ¶ added in v0.4.1
func (UnimplementedProbeServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
type UnimplementedProxyServer ¶ added in v0.4.1
type UnimplementedProxyServer struct { }
UnimplementedProxyServer must be embedded to have forward compatible implementations.
func (UnimplementedProxyServer) Respond ¶ added in v0.4.1
func (UnimplementedProxyServer) Respond(context.Context, *RespondRequest) (*RespondResponse, error)
type UnimplementedSearchServer ¶
type UnimplementedSearchServer struct { }
UnimplementedSearchServer must be embedded to have forward compatible implementations.
func (UnimplementedSearchServer) DeleteByID ¶ added in v0.3.0
func (UnimplementedSearchServer) DeleteByID(context.Context, *DeleteByIDRequest) (*DeleteByIDResponse, error)
func (UnimplementedSearchServer) Index ¶
func (UnimplementedSearchServer) Index(context.Context, *IndexObject) (*IndexResponse, error)
func (UnimplementedSearchServer) Search ¶
func (UnimplementedSearchServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
type UnimplementedSubscriptionServer ¶
type UnimplementedSubscriptionServer struct { }
UnimplementedSubscriptionServer must be embedded to have forward compatible implementations.
func (UnimplementedSubscriptionServer) CreateSubscription ¶
func (UnimplementedSubscriptionServer) CreateSubscription(context.Context, *CreateSubscriptionRequest) (*SubscriptionResponse, error)
func (UnimplementedSubscriptionServer) DeleteSubscription ¶
func (UnimplementedSubscriptionServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error)
func (UnimplementedSubscriptionServer) GetSubscription ¶
func (UnimplementedSubscriptionServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*SubscriptionResponse, error)
func (UnimplementedSubscriptionServer) ListSubscription ¶
func (UnimplementedSubscriptionServer) ListSubscription(context.Context, *ListSubscriptionRequest) (*ListSubscriptionResponse, error)
func (UnimplementedSubscriptionServer) UpdateSubscription ¶
func (UnimplementedSubscriptionServer) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*SubscriptionResponse, error)
type UnimplementedTSServer ¶ added in v0.4.1
type UnimplementedTSServer struct { }
UnimplementedTSServer must be embedded to have forward compatible implementations.
func (UnimplementedTSServer) DownloadTSData ¶ added in v0.4.1
func (UnimplementedTSServer) DownloadTSData(context.Context, *DownloadTSDataRequest) (*DownloadTSDataResponse, error)
func (UnimplementedTSServer) GetLatestEntities ¶ added in v0.4.1
func (UnimplementedTSServer) GetLatestEntities(context.Context, *GetLatestEntitiesRequest) (*GetLatestEntitiesResponse, error)
func (UnimplementedTSServer) GetTSData ¶ added in v0.4.1
func (UnimplementedTSServer) GetTSData(context.Context, *GetTSDataRequest) (*GetTSDataResponse, error)
type UnimplementedTopicServer ¶
type UnimplementedTopicServer struct { }
UnimplementedTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedTopicServer) TopicClusterEventHandler ¶ added in v0.4.1
func (UnimplementedTopicServer) TopicClusterEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
func (UnimplementedTopicServer) TopicEventHandler ¶
func (UnimplementedTopicServer) TopicEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
type UnsafeEntityServer ¶
type UnsafeEntityServer interface {
// contains filtered or unexported methods
}
UnsafeEntityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EntityServer will result in compilation errors.
type UnsafeProbeServer ¶ added in v0.4.1
type UnsafeProbeServer interface {
// contains filtered or unexported methods
}
UnsafeProbeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProbeServer will result in compilation errors.
type UnsafeProxyServer ¶ added in v0.4.1
type UnsafeProxyServer interface {
// contains filtered or unexported methods
}
UnsafeProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProxyServer will result in compilation errors.
type UnsafeSearchServer ¶
type UnsafeSearchServer interface {
// contains filtered or unexported methods
}
UnsafeSearchServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SearchServer will result in compilation errors.
type UnsafeSubscriptionServer ¶
type UnsafeSubscriptionServer interface {
// contains filtered or unexported methods
}
UnsafeSubscriptionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscriptionServer will result in compilation errors.
type UnsafeTSServer ¶ added in v0.4.1
type UnsafeTSServer interface {
// contains filtered or unexported methods
}
UnsafeTSServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TSServer will result in compilation errors.
type UnsafeTopicServer ¶
type UnsafeTopicServer interface {
// contains filtered or unexported methods
}
UnsafeTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TopicServer will result in compilation errors.
type UpdateEntityConfigsRequest ¶ added in v0.4.1
type UpdateEntityConfigsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` Configs *_struct.Value `protobuf:"bytes,5,opt,name=configs,proto3" json:"configs,omitempty"` // contains filtered or unexported fields }
Update(upsert) Entity Configs Request.
func (*UpdateEntityConfigsRequest) Descriptor
deprecated
added in
v0.4.1
func (*UpdateEntityConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateEntityConfigsRequest.ProtoReflect.Descriptor instead.
func (*UpdateEntityConfigsRequest) GetConfigs ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) GetConfigs() *_struct.Value
func (*UpdateEntityConfigsRequest) GetId ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) GetId() string
func (*UpdateEntityConfigsRequest) GetOwner ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) GetOwner() string
func (*UpdateEntityConfigsRequest) GetSource ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) GetSource() string
func (*UpdateEntityConfigsRequest) GetType ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) GetType() string
func (*UpdateEntityConfigsRequest) ProtoMessage ¶ added in v0.4.1
func (*UpdateEntityConfigsRequest) ProtoMessage()
func (*UpdateEntityConfigsRequest) ProtoReflect ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) ProtoReflect() protoreflect.Message
func (*UpdateEntityConfigsRequest) Reset ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) Reset()
func (*UpdateEntityConfigsRequest) String ¶ added in v0.4.1
func (x *UpdateEntityConfigsRequest) String() string
type UpdateEntityPropsRequest ¶ added in v0.4.1
type UpdateEntityPropsRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Properties *_struct.Value `protobuf:"bytes,5,opt,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
Update(upsert) Entity Properties Request.
func (*UpdateEntityPropsRequest) Descriptor
deprecated
added in
v0.4.1
func (*UpdateEntityPropsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateEntityPropsRequest.ProtoReflect.Descriptor instead.
func (*UpdateEntityPropsRequest) GetId ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) GetId() string
func (*UpdateEntityPropsRequest) GetOwner ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) GetOwner() string
func (*UpdateEntityPropsRequest) GetProperties ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) GetProperties() *_struct.Value
func (*UpdateEntityPropsRequest) GetSource ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) GetSource() string
func (*UpdateEntityPropsRequest) GetType ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) GetType() string
func (*UpdateEntityPropsRequest) ProtoMessage ¶ added in v0.4.1
func (*UpdateEntityPropsRequest) ProtoMessage()
func (*UpdateEntityPropsRequest) ProtoReflect ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) ProtoReflect() protoreflect.Message
func (*UpdateEntityPropsRequest) Reset ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) Reset()
func (*UpdateEntityPropsRequest) String ¶ added in v0.4.1
func (x *UpdateEntityPropsRequest) String() string
type UpdateEntityRequest ¶
type UpdateEntityRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Properties *_struct.Value `protobuf:"bytes,5,opt,name=properties,proto3" json:"properties,omitempty"` // contains filtered or unexported fields }
Update Entity Request.
func (*UpdateEntityRequest) Descriptor
deprecated
func (*UpdateEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateEntityRequest.ProtoReflect.Descriptor instead.
func (*UpdateEntityRequest) GetId ¶
func (x *UpdateEntityRequest) GetId() string
func (*UpdateEntityRequest) GetOwner ¶
func (x *UpdateEntityRequest) GetOwner() string
func (*UpdateEntityRequest) GetProperties ¶
func (x *UpdateEntityRequest) GetProperties() *_struct.Value
func (*UpdateEntityRequest) GetSource ¶
func (x *UpdateEntityRequest) GetSource() string
func (*UpdateEntityRequest) GetType ¶ added in v0.3.1
func (x *UpdateEntityRequest) GetType() string
func (*UpdateEntityRequest) ProtoMessage ¶
func (*UpdateEntityRequest) ProtoMessage()
func (*UpdateEntityRequest) ProtoReflect ¶
func (x *UpdateEntityRequest) ProtoReflect() protoreflect.Message
func (*UpdateEntityRequest) Reset ¶
func (x *UpdateEntityRequest) Reset()
func (*UpdateEntityRequest) String ¶
func (x *UpdateEntityRequest) String() string
type UpdateSubscriptionRequest ¶
type UpdateSubscriptionRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Subscription *SubscriptionObject `protobuf:"bytes,5,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
func (*UpdateSubscriptionRequest) Descriptor
deprecated
func (*UpdateSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*UpdateSubscriptionRequest) GetId ¶
func (x *UpdateSubscriptionRequest) GetId() string
func (*UpdateSubscriptionRequest) GetOwner ¶
func (x *UpdateSubscriptionRequest) GetOwner() string
func (*UpdateSubscriptionRequest) GetSource ¶
func (x *UpdateSubscriptionRequest) GetSource() string
func (*UpdateSubscriptionRequest) GetSubscription ¶
func (x *UpdateSubscriptionRequest) GetSubscription() *SubscriptionObject
func (*UpdateSubscriptionRequest) ProtoMessage ¶
func (*UpdateSubscriptionRequest) ProtoMessage()
func (*UpdateSubscriptionRequest) ProtoReflect ¶
func (x *UpdateSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*UpdateSubscriptionRequest) Reset ¶
func (x *UpdateSubscriptionRequest) Reset()
func (*UpdateSubscriptionRequest) String ¶
func (x *UpdateSubscriptionRequest) String() string
Source Files ¶
- entity.pb.go
- entity_grpc.pb.go
- entity_http.pb.go
- list.pb.go
- probe.pb.go
- probe_grpc.pb.go
- probe_http.pb.go
- proxy.pb.go
- proxy_grpc.pb.go
- proxy_http.pb.go
- search.pb.go
- search_grpc.pb.go
- search_http.pb.go
- subscription.pb.go
- subscription_grpc.pb.go
- subscription_http.pb.go
- topic.pb.go
- topic_grpc.pb.go
- topic_http.go
- ts.pb.go
- ts_grpc.pb.go
- ts_http.pb.go