v1

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2022 License: Apache-2.0 Imports: 24 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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)

View Source 
var File_api_core_v1_entity_proto protoreflect.FileDescriptor
View Source 
var File_api_core_v1_list_proto protoreflect.FileDescriptor
View Source 
var File_api_core_v1_probe_proto protoreflect.FileDescriptor
View Source 
var File_api_core_v1_proxy_proto protoreflect.FileDescriptor
View Source 
var File_api_core_v1_search_proto protoreflect.FileDescriptor
View Source 
var File_api_core_v1_subscription_proto protoreflect.FileDescriptor
View Source 
var File_api_core_v1_topic_proto protoreflect.FileDescriptor
View Source 
var File_api_core_v1_ts_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Mapper.ProtoReflect.Descriptor instead.

func (*Mapper) GetDescription added in v0.4.1 

func (x *Mapper) GetDescription() string

func (*Mapper) GetId added in v0.4.1 

func (x *Mapper) GetId() string

func (*Mapper) GetName added in v0.4.1 

func (x *Mapper) GetName() string

func (*Mapper) GetTql added in v0.4.1 

func (x *Mapper) GetTql() string

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

func (*Mapper) Reset added in v0.4.1 

func (x *Mapper) Reset()

func (*Mapper) String added in v0.4.1 

func (x *Mapper) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetDatacontenttype added in v0.4.1 

func (x *Metadata) GetDatacontenttype() string

func (*Metadata) GetId added in v0.4.1 

func (x *Metadata) GetId() string

func (*Metadata) GetPubsubname added in v0.4.1 

func (x *Metadata) GetPubsubname() string

func (*Metadata) GetSource added in v0.4.1 

func (x *Metadata) GetSource() string

func (*Metadata) GetSpecversion added in v0.4.1 

func (x *Metadata) GetSpecversion() string

func (*Metadata) GetSubject added in v0.4.1 

func (x *Metadata) GetSubject() string

func (*Metadata) GetTopic added in v0.4.1 

func (x *Metadata) GetTopic() string

func (*Metadata) GetType added in v0.4.1 

func (x *Metadata) GetType() string

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

func (*Metadata) Reset added in v0.4.1 

func (x *Metadata) Reset()

func (*Metadata) String added in v0.4.1 

func (x *Metadata) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Pager.ProtoReflect.Descriptor instead.

func (*Pager) GetLimit 

func (x *Pager) GetLimit() int32

func (*Pager) GetOffset 

func (x *Pager) GetOffset() int32

func (*Pager) GetReverse 

func (x *Pager) GetReverse() bool

func (*Pager) GetSort 

func (x *Pager) GetSort() string

func (*Pager) ProtoMessage 

func (*Pager) ProtoMessage()

func (*Pager) ProtoReflect 

func (x *Pager) ProtoReflect() protoreflect.Message

func (*Pager) Reset 

func (x *Pager) Reset()

func (*Pager) String 

func (x *Pager) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use PatchData.ProtoReflect.Descriptor instead.

func (*PatchData) GetOperator added in v0.2.1 

func (x *PatchData) GetOperator() string

func (*PatchData) GetPath added in v0.2.1 

func (x *PatchData) GetPath() string

func (*PatchData) GetValue added in v0.2.1 

func (x *PatchData) GetValue() *_struct.Value

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

func (*PatchData) Reset added in v0.2.1 

func (x *PatchData) Reset()

func (*PatchData) String added in v0.2.1 

func (x *PatchData) String() string

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.