evaluatord

package
v1.2.15 Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2022 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_add_configs_to_timer_proto protoreflect.FileDescriptor
View Source 
var File_add_sources_to_evaluator_proto protoreflect.FileDescriptor
View Source 
var File_create_evaluator_proto protoreflect.FileDescriptor
View Source 
var File_create_timer_proto protoreflect.FileDescriptor
View Source 
var File_delete_evaluator_proto protoreflect.FileDescriptor
View Source 
var File_delete_timer_proto protoreflect.FileDescriptor
View Source 
var File_get_evaluator_proto protoreflect.FileDescriptor
View Source 
var File_get_task_proto protoreflect.FileDescriptor
View Source 
var File_get_timer_proto protoreflect.FileDescriptor
View Source 
var File_list_evaluators_by_source_proto protoreflect.FileDescriptor
View Source 
var File_list_evaluators_proto protoreflect.FileDescriptor
View Source 
var File_list_tasks_by_source_proto protoreflect.FileDescriptor
View Source 
var File_list_timers_proto protoreflect.FileDescriptor
View Source 
var File_model_proto protoreflect.FileDescriptor
View Source 
var File_patch_evaluator_proto protoreflect.FileDescriptor
View Source 
var File_patch_timer_proto protoreflect.FileDescriptor
View Source 
var File_query_storage_by_device_proto protoreflect.FileDescriptor
View Source 
var File_remove_configs_from_timer_proto protoreflect.FileDescriptor
View Source 
var File_remove_sources_from_evaluator_proto protoreflect.FileDescriptor
View Source 
var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterEvaluatordServiceServer 

func RegisterEvaluatordServiceServer(s *grpc.Server, srv EvaluatordServiceServer)

Types

type AddConfigsToTimerRequest 

type AddConfigsToTimerRequest struct {
	Timer   *OpTimer            `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	Configs []*deviced.OpConfig `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*AddConfigsToTimerRequest) Descriptor deprecated 

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

Deprecated: Use AddConfigsToTimerRequest.ProtoReflect.Descriptor instead.

func (*AddConfigsToTimerRequest) GetConfigs 

func (x *AddConfigsToTimerRequest) GetConfigs() []*deviced.OpConfig

func (*AddConfigsToTimerRequest) GetTimer 

func (x *AddConfigsToTimerRequest) GetTimer() *OpTimer

func (*AddConfigsToTimerRequest) ProtoMessage 

func (*AddConfigsToTimerRequest) ProtoMessage()

func (*AddConfigsToTimerRequest) ProtoReflect added in v1.2.14 

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

func (*AddConfigsToTimerRequest) Reset 

func (x *AddConfigsToTimerRequest) Reset()

func (*AddConfigsToTimerRequest) String 

func (x *AddConfigsToTimerRequest) String() string

type AddSourcesToEvaluatorRequest 

type AddSourcesToEvaluatorRequest struct {
	Sources   []*OpResource `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	Evaluator *OpEvaluator  `protobuf:"bytes,2,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*AddSourcesToEvaluatorRequest) Descriptor deprecated 

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

Deprecated: Use AddSourcesToEvaluatorRequest.ProtoReflect.Descriptor instead.

func (*AddSourcesToEvaluatorRequest) GetEvaluator 

func (x *AddSourcesToEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*AddSourcesToEvaluatorRequest) GetSources 

func (x *AddSourcesToEvaluatorRequest) GetSources() []*OpResource

func (*AddSourcesToEvaluatorRequest) ProtoMessage 

func (*AddSourcesToEvaluatorRequest) ProtoMessage()

func (*AddSourcesToEvaluatorRequest) ProtoReflect added in v1.2.14 

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

func (*AddSourcesToEvaluatorRequest) Reset 

func (x *AddSourcesToEvaluatorRequest) Reset()

func (*AddSourcesToEvaluatorRequest) String 

func (x *AddSourcesToEvaluatorRequest) String() string

type CreateEvaluatorRequest 

type CreateEvaluatorRequest struct {
	Evaluator *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateEvaluatorRequest) Descriptor deprecated 

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

Deprecated: Use CreateEvaluatorRequest.ProtoReflect.Descriptor instead.

func (*CreateEvaluatorRequest) GetEvaluator 

func (x *CreateEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*CreateEvaluatorRequest) ProtoMessage 

func (*CreateEvaluatorRequest) ProtoMessage()

func (*CreateEvaluatorRequest) ProtoReflect added in v1.2.14 

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

func (*CreateEvaluatorRequest) Reset 

func (x *CreateEvaluatorRequest) Reset()

func (*CreateEvaluatorRequest) String 

func (x *CreateEvaluatorRequest) String() string

type CreateEvaluatorResponse 

type CreateEvaluatorResponse struct {
	Evaluator *Evaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateEvaluatorResponse) Descriptor deprecated 

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

Deprecated: Use CreateEvaluatorResponse.ProtoReflect.Descriptor instead.

func (*CreateEvaluatorResponse) GetEvaluator 

func (x *CreateEvaluatorResponse) GetEvaluator() *Evaluator

func (*CreateEvaluatorResponse) ProtoMessage 

func (*CreateEvaluatorResponse) ProtoMessage()

func (*CreateEvaluatorResponse) ProtoReflect added in v1.2.14 

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

func (*CreateEvaluatorResponse) Reset 

func (x *CreateEvaluatorResponse) Reset()

func (*CreateEvaluatorResponse) String 

func (x *CreateEvaluatorResponse) String() string

type CreateTimerRequest 

type CreateTimerRequest struct {
	Timer *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTimerRequest) Descriptor deprecated 

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

Deprecated: Use CreateTimerRequest.ProtoReflect.Descriptor instead.

func (*CreateTimerRequest) GetTimer 

func (x *CreateTimerRequest) GetTimer() *OpTimer

func (*CreateTimerRequest) ProtoMessage 

func (*CreateTimerRequest) ProtoMessage()

func (*CreateTimerRequest) ProtoReflect added in v1.2.14 

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

func (*CreateTimerRequest) Reset 

func (x *CreateTimerRequest) Reset()

func (*CreateTimerRequest) String 

func (x *CreateTimerRequest) String() string

type CreateTimerResponse 

type CreateTimerResponse struct {
	Timer *Timer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTimerResponse) Descriptor deprecated 

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

Deprecated: Use CreateTimerResponse.ProtoReflect.Descriptor instead.

func (*CreateTimerResponse) GetTimer 

func (x *CreateTimerResponse) GetTimer() *Timer

func (*CreateTimerResponse) ProtoMessage 

func (*CreateTimerResponse) ProtoMessage()

func (*CreateTimerResponse) ProtoReflect added in v1.2.14 

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

func (*CreateTimerResponse) Reset 

func (x *CreateTimerResponse) Reset()

func (*CreateTimerResponse) String 

func (x *CreateTimerResponse) String() string

type DeleteEvaluatorRequest 

type DeleteEvaluatorRequest struct {
	Evaluator *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteEvaluatorRequest) Descriptor deprecated 

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

Deprecated: Use DeleteEvaluatorRequest.ProtoReflect.Descriptor instead.

func (*DeleteEvaluatorRequest) GetEvaluator 

func (x *DeleteEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*DeleteEvaluatorRequest) ProtoMessage 

func (*DeleteEvaluatorRequest) ProtoMessage()

func (*DeleteEvaluatorRequest) ProtoReflect added in v1.2.14 

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

func (*DeleteEvaluatorRequest) Reset 

func (x *DeleteEvaluatorRequest) Reset()

func (*DeleteEvaluatorRequest) String 

func (x *DeleteEvaluatorRequest) String() string

type DeleteTimerRequest 

type DeleteTimerRequest struct {
	Timer *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTimerRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTimerRequest.ProtoReflect.Descriptor instead.

func (*DeleteTimerRequest) GetTimer 

func (x *DeleteTimerRequest) GetTimer() *OpTimer

func (*DeleteTimerRequest) ProtoMessage 

func (*DeleteTimerRequest) ProtoMessage()

func (*DeleteTimerRequest) ProtoReflect added in v1.2.14 

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

func (*DeleteTimerRequest) Reset 

func (x *DeleteTimerRequest) Reset()

func (*DeleteTimerRequest) String 

func (x *DeleteTimerRequest) String() string

type Evaluator 

type Evaluator struct {
	Id          string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias       string           `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description string           `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Sources     []*Resource      `protobuf:"bytes,8,rep,name=sources,proto3" json:"sources,omitempty"`
	Operator    *Operator        `protobuf:"bytes,10,opt,name=operator,proto3" json:"operator,omitempty"`
	Config      *structpb.Struct `protobuf:"bytes,11,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*Evaluator) Descriptor deprecated 

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

Deprecated: Use Evaluator.ProtoReflect.Descriptor instead.

func (*Evaluator) GetAlias 

func (x *Evaluator) GetAlias() string

func (*Evaluator) GetConfig 

func (x *Evaluator) GetConfig() *structpb.Struct

func (*Evaluator) GetDescription 

func (x *Evaluator) GetDescription() string

func (*Evaluator) GetId 

func (x *Evaluator) GetId() string

func (*Evaluator) GetOperator 

func (x *Evaluator) GetOperator() *Operator

func (*Evaluator) GetSources 

func (x *Evaluator) GetSources() []*Resource

func (*Evaluator) ProtoMessage 

func (*Evaluator) ProtoMessage()

func (*Evaluator) ProtoReflect added in v1.2.14 

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

func (*Evaluator) Reset 

func (x *Evaluator) Reset()

func (*Evaluator) String 

func (x *Evaluator) String() string

type EvaluatordServiceClient 

type EvaluatordServiceClient interface {
	CreateEvaluator(ctx context.Context, in *CreateEvaluatorRequest, opts ...grpc.CallOption) (*CreateEvaluatorResponse, error)
	DeleteEvaluator(ctx context.Context, in *DeleteEvaluatorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PatchEvaluator(ctx context.Context, in *PatchEvaluatorRequest, opts ...grpc.CallOption) (*PatchEvaluatorResponse, error)
	GetEvaluator(ctx context.Context, in *GetEvaluatorRequest, opts ...grpc.CallOption) (*GetEvaluatorResponse, error)
	ListEvaluators(ctx context.Context, in *ListEvaluatorsRequest, opts ...grpc.CallOption) (*ListEvaluatorsResponse, error)
	AddSourcesToEvaluator(ctx context.Context, in *AddSourcesToEvaluatorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveSourcesFromEvaluator(ctx context.Context, in *RemoveSourcesFromEvaluatorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListEvaluatorsBySource(ctx context.Context, in *ListEvaluatorsBySourceRequest, opts ...grpc.CallOption) (*ListEvaluatorsBySourceResponse, error)
	// Task
	ListTasksBySource(ctx context.Context, in *ListTasksBySourceRequest, opts ...grpc.CallOption) (*ListTasksBySourceResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error)
	// Storage
	QueryStorageByDevice(ctx context.Context, in *QueryStorageByDeviceRequest, opts ...grpc.CallOption) (*QueryStorageByDeviceResponse, error)
	// Timer
	CreateTimer(ctx context.Context, in *CreateTimerRequest, opts ...grpc.CallOption) (*CreateTimerResponse, error)
	DeleteTimer(ctx context.Context, in *DeleteTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PatchTimer(ctx context.Context, in *PatchTimerRequest, opts ...grpc.CallOption) (*PatchTimerResponse, error)
	GetTimer(ctx context.Context, in *GetTimerRequest, opts ...grpc.CallOption) (*GetTimerResponse, error)
	ListTimers(ctx context.Context, in *ListTimersRequest, opts ...grpc.CallOption) (*ListTimersResponse, error)
	AddConfigsToTimer(ctx context.Context, in *AddConfigsToTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveConfigsFromTimer(ctx context.Context, in *RemoveConfigsFromTimerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

EvaluatordServiceClient is the client API for EvaluatordService service.

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

func NewEvaluatordServiceClient 

func NewEvaluatordServiceClient(cc grpc.ClientConnInterface) EvaluatordServiceClient

type EvaluatordServiceServer 

type EvaluatordServiceServer interface {
	CreateEvaluator(context.Context, *CreateEvaluatorRequest) (*CreateEvaluatorResponse, error)
	DeleteEvaluator(context.Context, *DeleteEvaluatorRequest) (*emptypb.Empty, error)
	PatchEvaluator(context.Context, *PatchEvaluatorRequest) (*PatchEvaluatorResponse, error)
	GetEvaluator(context.Context, *GetEvaluatorRequest) (*GetEvaluatorResponse, error)
	ListEvaluators(context.Context, *ListEvaluatorsRequest) (*ListEvaluatorsResponse, error)
	AddSourcesToEvaluator(context.Context, *AddSourcesToEvaluatorRequest) (*emptypb.Empty, error)
	RemoveSourcesFromEvaluator(context.Context, *RemoveSourcesFromEvaluatorRequest) (*emptypb.Empty, error)
	ListEvaluatorsBySource(context.Context, *ListEvaluatorsBySourceRequest) (*ListEvaluatorsBySourceResponse, error)
	// Task
	ListTasksBySource(context.Context, *ListTasksBySourceRequest) (*ListTasksBySourceResponse, error)
	GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
	// Storage
	QueryStorageByDevice(context.Context, *QueryStorageByDeviceRequest) (*QueryStorageByDeviceResponse, error)
	// Timer
	CreateTimer(context.Context, *CreateTimerRequest) (*CreateTimerResponse, error)
	DeleteTimer(context.Context, *DeleteTimerRequest) (*emptypb.Empty, error)
	PatchTimer(context.Context, *PatchTimerRequest) (*PatchTimerResponse, error)
	GetTimer(context.Context, *GetTimerRequest) (*GetTimerResponse, error)
	ListTimers(context.Context, *ListTimersRequest) (*ListTimersResponse, error)
	AddConfigsToTimer(context.Context, *AddConfigsToTimerRequest) (*emptypb.Empty, error)
	RemoveConfigsFromTimer(context.Context, *RemoveConfigsFromTimerRequest) (*emptypb.Empty, error)
}

EvaluatordServiceServer is the server API for EvaluatordService service.

type GetEvaluatorRequest 

type GetEvaluatorRequest struct {
	Evaluator *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEvaluatorRequest) Descriptor deprecated 

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

Deprecated: Use GetEvaluatorRequest.ProtoReflect.Descriptor instead.

func (*GetEvaluatorRequest) GetEvaluator 

func (x *GetEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*GetEvaluatorRequest) ProtoMessage 

func (*GetEvaluatorRequest) ProtoMessage()

func (*GetEvaluatorRequest) ProtoReflect added in v1.2.14 

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

func (*GetEvaluatorRequest) Reset 

func (x *GetEvaluatorRequest) Reset()

func (*GetEvaluatorRequest) String 

func (x *GetEvaluatorRequest) String() string

type GetEvaluatorResponse 

type GetEvaluatorResponse struct {
	Evaluator *Evaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEvaluatorResponse) Descriptor deprecated 

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

Deprecated: Use GetEvaluatorResponse.ProtoReflect.Descriptor instead.

func (*GetEvaluatorResponse) GetEvaluator 

func (x *GetEvaluatorResponse) GetEvaluator() *Evaluator

func (*GetEvaluatorResponse) ProtoMessage 

func (*GetEvaluatorResponse) ProtoMessage()

func (*GetEvaluatorResponse) ProtoReflect added in v1.2.14 

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

func (*GetEvaluatorResponse) Reset 

func (x *GetEvaluatorResponse) Reset()

func (*GetEvaluatorResponse) String 

func (x *GetEvaluatorResponse) String() string

type GetTaskRequest 

type GetTaskRequest struct {
	Task *OpTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetTask 

func (x *GetTaskRequest) GetTask() *OpTask

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect added in v1.2.14 

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

func (*GetTaskRequest) Reset 

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (x *GetTaskRequest) String() string

type GetTaskResponse 

type GetTaskResponse struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskResponse) Descriptor deprecated 

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

Deprecated: Use GetTaskResponse.ProtoReflect.Descriptor instead.

func (*GetTaskResponse) GetTask 

func (x *GetTaskResponse) GetTask() *Task

func (*GetTaskResponse) ProtoMessage 

func (*GetTaskResponse) ProtoMessage()

func (*GetTaskResponse) ProtoReflect added in v1.2.14 

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

func (*GetTaskResponse) Reset 

func (x *GetTaskResponse) Reset()

func (*GetTaskResponse) String 

func (x *GetTaskResponse) String() string

type GetTimerRequest 

type GetTimerRequest struct {
	Timer *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimerRequest) Descriptor deprecated 

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

Deprecated: Use GetTimerRequest.ProtoReflect.Descriptor instead.

func (*GetTimerRequest) GetTimer 

func (x *GetTimerRequest) GetTimer() *OpTimer

func (*GetTimerRequest) ProtoMessage 

func (*GetTimerRequest) ProtoMessage()

func (*GetTimerRequest) ProtoReflect added in v1.2.14 

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

func (*GetTimerRequest) Reset 

func (x *GetTimerRequest) Reset()

func (*GetTimerRequest) String 

func (x *GetTimerRequest) String() string

type GetTimerResponse 

type GetTimerResponse struct {
	Timer *Timer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimerResponse) Descriptor deprecated 

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

Deprecated: Use GetTimerResponse.ProtoReflect.Descriptor instead.

func (*GetTimerResponse) GetTimer 

func (x *GetTimerResponse) GetTimer() *Timer

func (*GetTimerResponse) ProtoMessage 

func (*GetTimerResponse) ProtoMessage()

func (*GetTimerResponse) ProtoReflect added in v1.2.14 

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

func (*GetTimerResponse) Reset 

func (x *GetTimerResponse) Reset()

func (*GetTimerResponse) String 

func (x *GetTimerResponse) String() string

type ListEvaluatorsBySourceRequest 

type ListEvaluatorsBySourceRequest struct {
	Source *OpResource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEvaluatorsBySourceRequest) Descriptor deprecated 

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

Deprecated: Use ListEvaluatorsBySourceRequest.ProtoReflect.Descriptor instead.

func (*ListEvaluatorsBySourceRequest) GetSource 

func (x *ListEvaluatorsBySourceRequest) GetSource() *OpResource

func (*ListEvaluatorsBySourceRequest) ProtoMessage 

func (*ListEvaluatorsBySourceRequest) ProtoMessage()

func (*ListEvaluatorsBySourceRequest) ProtoReflect added in v1.2.14 

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

func (*ListEvaluatorsBySourceRequest) Reset 

func (x *ListEvaluatorsBySourceRequest) Reset()

func (*ListEvaluatorsBySourceRequest) String 

func (x *ListEvaluatorsBySourceRequest) String() string

type ListEvaluatorsBySourceResponse 

type ListEvaluatorsBySourceResponse struct {
	Evaluators []*Evaluator `protobuf:"bytes,1,rep,name=evaluators,proto3" json:"evaluators,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEvaluatorsBySourceResponse) Descriptor deprecated 

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

Deprecated: Use ListEvaluatorsBySourceResponse.ProtoReflect.Descriptor instead.

func (*ListEvaluatorsBySourceResponse) GetEvaluators 

func (x *ListEvaluatorsBySourceResponse) GetEvaluators() []*Evaluator

func (*ListEvaluatorsBySourceResponse) ProtoMessage 

func (*ListEvaluatorsBySourceResponse) ProtoMessage()

func (*ListEvaluatorsBySourceResponse) ProtoReflect added in v1.2.14 

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

func (*ListEvaluatorsBySourceResponse) Reset 

func (x *ListEvaluatorsBySourceResponse) Reset()

func (*ListEvaluatorsBySourceResponse) String 

func (x *ListEvaluatorsBySourceResponse) String() string

type ListEvaluatorsRequest 

type ListEvaluatorsRequest struct {
	Evaluator *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEvaluatorsRequest) Descriptor deprecated 

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

Deprecated: Use ListEvaluatorsRequest.ProtoReflect.Descriptor instead.

func (*ListEvaluatorsRequest) GetEvaluator 

func (x *ListEvaluatorsRequest) GetEvaluator() *OpEvaluator

func (*ListEvaluatorsRequest) ProtoMessage 

func (*ListEvaluatorsRequest) ProtoMessage()

func (*ListEvaluatorsRequest) ProtoReflect added in v1.2.14 

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

func (*ListEvaluatorsRequest) Reset 

func (x *ListEvaluatorsRequest) Reset()

func (*ListEvaluatorsRequest) String 

func (x *ListEvaluatorsRequest) String() string

type ListEvaluatorsResponse 

type ListEvaluatorsResponse struct {
	Evaluators []*Evaluator `protobuf:"bytes,1,rep,name=evaluators,proto3" json:"evaluators,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEvaluatorsResponse) Descriptor deprecated 

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

Deprecated: Use ListEvaluatorsResponse.ProtoReflect.Descriptor instead.

func (*ListEvaluatorsResponse) GetEvaluators 

func (x *ListEvaluatorsResponse) GetEvaluators() []*Evaluator

func (*ListEvaluatorsResponse) ProtoMessage 

func (*ListEvaluatorsResponse) ProtoMessage()

func (*ListEvaluatorsResponse) ProtoReflect added in v1.2.14 

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

func (*ListEvaluatorsResponse) Reset 

func (x *ListEvaluatorsResponse) Reset()

func (*ListEvaluatorsResponse) String 

func (x *ListEvaluatorsResponse) String() string

type ListTasksBySourceRequest 

type ListTasksBySourceRequest struct {
	Source    *OpResource            `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	RangeFrom *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=range_from,json=rangeFrom,proto3" json:"range_from,omitempty"`
	RangeTo   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=range_to,json=rangeTo,proto3" json:"range_to,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksBySourceRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksBySourceRequest.ProtoReflect.Descriptor instead.

func (*ListTasksBySourceRequest) GetRangeFrom 

func (x *ListTasksBySourceRequest) GetRangeFrom() *timestamppb.Timestamp

func (*ListTasksBySourceRequest) GetRangeTo 

func (x *ListTasksBySourceRequest) GetRangeTo() *timestamppb.Timestamp

func (*ListTasksBySourceRequest) GetSource 

func (x *ListTasksBySourceRequest) GetSource() *OpResource

func (*ListTasksBySourceRequest) ProtoMessage 

func (*ListTasksBySourceRequest) ProtoMessage()

func (*ListTasksBySourceRequest) ProtoReflect added in v1.2.14 

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

func (*ListTasksBySourceRequest) Reset 

func (x *ListTasksBySourceRequest) Reset()

func (*ListTasksBySourceRequest) String 

func (x *ListTasksBySourceRequest) String() string

type ListTasksBySourceResponse 

type ListTasksBySourceResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksBySourceResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksBySourceResponse.ProtoReflect.Descriptor instead.

func (*ListTasksBySourceResponse) GetTasks 

func (x *ListTasksBySourceResponse) GetTasks() []*Task

func (*ListTasksBySourceResponse) ProtoMessage 

func (*ListTasksBySourceResponse) ProtoMessage()

func (*ListTasksBySourceResponse) ProtoReflect added in v1.2.14 

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

func (*ListTasksBySourceResponse) Reset 

func (x *ListTasksBySourceResponse) Reset()

func (*ListTasksBySourceResponse) String 

func (x *ListTasksBySourceResponse) String() string

type ListTimersRequest 

type ListTimersRequest struct {
	Timer *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTimersRequest) Descriptor deprecated 

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

Deprecated: Use ListTimersRequest.ProtoReflect.Descriptor instead.

func (*ListTimersRequest) GetTimer 

func (x *ListTimersRequest) GetTimer() *OpTimer

func (*ListTimersRequest) ProtoMessage 

func (*ListTimersRequest) ProtoMessage()

func (*ListTimersRequest) ProtoReflect added in v1.2.14 

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

func (*ListTimersRequest) Reset 

func (x *ListTimersRequest) Reset()

func (*ListTimersRequest) String 

func (x *ListTimersRequest) String() string

type ListTimersResponse 

type ListTimersResponse struct {
	Timers []*Timer `protobuf:"bytes,1,rep,name=timers,proto3" json:"timers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTimersResponse) Descriptor deprecated 

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

Deprecated: Use ListTimersResponse.ProtoReflect.Descriptor instead.

func (*ListTimersResponse) GetTimers 

func (x *ListTimersResponse) GetTimers() []*Timer

func (*ListTimersResponse) ProtoMessage 

func (*ListTimersResponse) ProtoMessage()

func (*ListTimersResponse) ProtoReflect added in v1.2.14 

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

func (*ListTimersResponse) Reset 

func (x *ListTimersResponse) Reset()

func (*ListTimersResponse) String 

func (x *ListTimersResponse) String() string

type LuaDescriptor 

type LuaDescriptor struct {
	Code string `protobuf:"bytes,8,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*LuaDescriptor) Descriptor deprecated 

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

Deprecated: Use LuaDescriptor.ProtoReflect.Descriptor instead.

func (*LuaDescriptor) GetCode 

func (x *LuaDescriptor) GetCode() string

func (*LuaDescriptor) ProtoMessage 

func (*LuaDescriptor) ProtoMessage()

func (*LuaDescriptor) ProtoReflect added in v1.2.14 

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

func (*LuaDescriptor) Reset 

func (x *LuaDescriptor) Reset()

func (*LuaDescriptor) String 

func (x *LuaDescriptor) String() string

type OpEvaluator 

type OpEvaluator struct {
	Id          *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias       *wrapperspb.StringValue `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description *wrapperspb.StringValue `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Sources     []*OpResource           `protobuf:"bytes,8,rep,name=sources,proto3" json:"sources,omitempty"`
	Operator    *OpOperator             `protobuf:"bytes,10,opt,name=operator,proto3" json:"operator,omitempty"`
	Config      *structpb.Struct        `protobuf:"bytes,11,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*OpEvaluator) Descriptor deprecated 

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

Deprecated: Use OpEvaluator.ProtoReflect.Descriptor instead.

func (*OpEvaluator) GetAlias 

func (x *OpEvaluator) GetAlias() *wrapperspb.StringValue

func (*OpEvaluator) GetConfig 

func (x *OpEvaluator) GetConfig() *structpb.Struct

func (*OpEvaluator) GetDescription 

func (x *OpEvaluator) GetDescription() *wrapperspb.StringValue

func (*OpEvaluator) GetId 

func (x *OpEvaluator) GetId() *wrapperspb.StringValue

func (*OpEvaluator) GetOperator 

func (x *OpEvaluator) GetOperator() *OpOperator

func (*OpEvaluator) GetSources 

func (x *OpEvaluator) GetSources() []*OpResource

func (*OpEvaluator) ProtoMessage 

func (*OpEvaluator) ProtoMessage()

func (*OpEvaluator) ProtoReflect added in v1.2.14 

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

func (*OpEvaluator) Reset 

func (x *OpEvaluator) Reset()

func (*OpEvaluator) String 

func (x *OpEvaluator) String() string

type OpLuaDescriptor 

type OpLuaDescriptor struct {
	Code *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*OpLuaDescriptor) Descriptor deprecated 

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

Deprecated: Use OpLuaDescriptor.ProtoReflect.Descriptor instead.

func (*OpLuaDescriptor) GetCode 

func (x *OpLuaDescriptor) GetCode() *wrapperspb.StringValue

func (*OpLuaDescriptor) ProtoMessage 

func (*OpLuaDescriptor) ProtoMessage()

func (*OpLuaDescriptor) ProtoReflect added in v1.2.14 

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

func (*OpLuaDescriptor) Reset 

func (x *OpLuaDescriptor) Reset()

func (*OpLuaDescriptor) String 

func (x *OpLuaDescriptor) String() string

type OpOperator 

type OpOperator struct {
	Id          *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias       *wrapperspb.StringValue `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description *wrapperspb.StringValue `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Driver      *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=driver,proto3" json:"driver,omitempty"`
	// Types that are assignable to Descriptor_:
	//	*OpOperator_Lua
	Descriptor_ isOpOperator_Descriptor_ `protobuf_oneof:"descriptor"`
	// contains filtered or unexported fields
}

func (*OpOperator) Descriptor deprecated 

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

Deprecated: Use OpOperator.ProtoReflect.Descriptor instead.

func (*OpOperator) GetAlias 

func (x *OpOperator) GetAlias() *wrapperspb.StringValue

func (*OpOperator) GetDescription 

func (x *OpOperator) GetDescription() *wrapperspb.StringValue

func (*OpOperator) GetDescriptor_ 

func (m *OpOperator) GetDescriptor_() isOpOperator_Descriptor_

func (*OpOperator) GetDriver 

func (x *OpOperator) GetDriver() *wrapperspb.StringValue

func (*OpOperator) GetId 

func (x *OpOperator) GetId() *wrapperspb.StringValue

func (*OpOperator) GetLua 

func (x *OpOperator) GetLua() *OpLuaDescriptor

func (*OpOperator) ProtoMessage 

func (*OpOperator) ProtoMessage()

func (*OpOperator) ProtoReflect added in v1.2.14 

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

func (*OpOperator) Reset 

func (x *OpOperator) Reset()

func (*OpOperator) String 

func (x *OpOperator) String() string

type OpOperator_Lua 

type OpOperator_Lua struct {
	Lua *OpLuaDescriptor `protobuf:"bytes,32,opt,name=lua,proto3,oneof"`
}

type OpResource 

type OpResource struct {
	Id   *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*OpResource) Descriptor deprecated 

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

Deprecated: Use OpResource.ProtoReflect.Descriptor instead.

func (*OpResource) GetId 

func (x *OpResource) GetId() *wrapperspb.StringValue

func (*OpResource) GetType 

func (x *OpResource) GetType() *wrapperspb.StringValue

func (*OpResource) ProtoMessage 

func (*OpResource) ProtoMessage()

func (*OpResource) ProtoReflect added in v1.2.14 

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

func (*OpResource) Reset 

func (x *OpResource) Reset()

func (*OpResource) String 

func (x *OpResource) String() string

type OpTask 

type OpTask struct {
	Id           *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt    *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt    *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	CurrentState *OpTaskState            `protobuf:"bytes,4,opt,name=current_state,json=currentState,proto3" json:"current_state,omitempty"`
	Source       *OpResource             `protobuf:"bytes,8,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*OpTask) Descriptor deprecated 

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

Deprecated: Use OpTask.ProtoReflect.Descriptor instead.

func (*OpTask) GetCreatedAt 

func (x *OpTask) GetCreatedAt() *timestamppb.Timestamp

func (*OpTask) GetCurrentState 

func (x *OpTask) GetCurrentState() *OpTaskState

func (*OpTask) GetId 

func (x *OpTask) GetId() *wrapperspb.StringValue

func (*OpTask) GetSource 

func (x *OpTask) GetSource() *OpResource

func (*OpTask) GetUpdatedAt 

func (x *OpTask) GetUpdatedAt() *timestamppb.Timestamp

func (*OpTask) ProtoMessage 

func (*OpTask) ProtoMessage()

func (*OpTask) ProtoReflect added in v1.2.14 

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

func (*OpTask) Reset 

func (x *OpTask) Reset()

func (*OpTask) String 

func (x *OpTask) String() string

type OpTaskState 

type OpTaskState struct {
	At    *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	State state.TaskState        `protobuf:"varint,2,opt,name=state,proto3,enum=ai.metathings.constant.state.TaskState" json:"state,omitempty"`
	Tags  *structpb.Struct       `protobuf:"bytes,8,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*OpTaskState) Descriptor deprecated 

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

Deprecated: Use OpTaskState.ProtoReflect.Descriptor instead.

func (*OpTaskState) GetAt 

func (x *OpTaskState) GetAt() *timestamppb.Timestamp

func (*OpTaskState) GetState 

func (x *OpTaskState) GetState() state.TaskState

func (*OpTaskState) GetTags 

func (x *OpTaskState) GetTags() *structpb.Struct

func (*OpTaskState) ProtoMessage 

func (*OpTaskState) ProtoMessage()

func (*OpTaskState) ProtoReflect added in v1.2.14 

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

func (*OpTaskState) Reset 

func (x *OpTaskState) Reset()

func (*OpTaskState) String 

func (x *OpTaskState) String() string

type OpTimer 

type OpTimer struct {
	Id          *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias       *wrapperspb.StringValue `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description *wrapperspb.StringValue `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Schedule    *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Timezone    *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=timezone,proto3" json:"timezone,omitempty"`
	Enabled     *wrapperspb.BoolValue   `protobuf:"bytes,10,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Configs     []*deviced.OpConfig     `protobuf:"bytes,11,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*OpTimer) Descriptor deprecated 

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

Deprecated: Use OpTimer.ProtoReflect.Descriptor instead.

func (*OpTimer) GetAlias 

func (x *OpTimer) GetAlias() *wrapperspb.StringValue

func (*OpTimer) GetConfigs 

func (x *OpTimer) GetConfigs() []*deviced.OpConfig

func (*OpTimer) GetDescription 

func (x *OpTimer) GetDescription() *wrapperspb.StringValue

func (*OpTimer) GetEnabled 

func (x *OpTimer) GetEnabled() *wrapperspb.BoolValue

func (*OpTimer) GetId 

func (x *OpTimer) GetId() *wrapperspb.StringValue

func (*OpTimer) GetSchedule 

func (x *OpTimer) GetSchedule() *wrapperspb.StringValue

func (*OpTimer) GetTimezone 

func (x *OpTimer) GetTimezone() *wrapperspb.StringValue

func (*OpTimer) ProtoMessage 

func (*OpTimer) ProtoMessage()

func (*OpTimer) ProtoReflect added in v1.2.14 

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

func (*OpTimer) Reset 

func (x *OpTimer) Reset()

func (*OpTimer) String 

func (x *OpTimer) String() string

type Operator 

type Operator struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias       string `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description string `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Driver      string `protobuf:"bytes,8,opt,name=driver,proto3" json:"driver,omitempty"`
	// Types that are assignable to Descriptor_:
	//	*Operator_Lua
	Descriptor_ isOperator_Descriptor_ `protobuf_oneof:"descriptor"`
	// contains filtered or unexported fields
}

func (*Operator) Descriptor deprecated 

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

Deprecated: Use Operator.ProtoReflect.Descriptor instead.

func (*Operator) GetAlias 

func (x *Operator) GetAlias() string

func (*Operator) GetDescription 

func (x *Operator) GetDescription() string

func (*Operator) GetDescriptor_ 

func (m *Operator) GetDescriptor_() isOperator_Descriptor_

func (*Operator) GetDriver 

func (x *Operator) GetDriver() string

func (*Operator) GetId 

func (x *Operator) GetId() string

func (*Operator) GetLua 

func (x *Operator) GetLua() *LuaDescriptor

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) ProtoReflect added in v1.2.14 

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

func (*Operator) Reset 

func (x *Operator) Reset()

func (*Operator) String 

func (x *Operator) String() string

type Operator_Lua 

type Operator_Lua struct {
	Lua *LuaDescriptor `protobuf:"bytes,32,opt,name=lua,proto3,oneof"`
}

type PatchEvaluatorRequest 

type PatchEvaluatorRequest struct {
	Evaluator *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchEvaluatorRequest) Descriptor deprecated 

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

Deprecated: Use PatchEvaluatorRequest.ProtoReflect.Descriptor instead.

func (*PatchEvaluatorRequest) GetEvaluator 

func (x *PatchEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*PatchEvaluatorRequest) ProtoMessage 

func (*PatchEvaluatorRequest) ProtoMessage()

func (*PatchEvaluatorRequest) ProtoReflect added in v1.2.14 

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

func (*PatchEvaluatorRequest) Reset 

func (x *PatchEvaluatorRequest) Reset()

func (*PatchEvaluatorRequest) String 

func (x *PatchEvaluatorRequest) String() string

type PatchEvaluatorResponse 

type PatchEvaluatorResponse struct {
	Evaluator *Evaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchEvaluatorResponse) Descriptor deprecated 

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

Deprecated: Use PatchEvaluatorResponse.ProtoReflect.Descriptor instead.

func (*PatchEvaluatorResponse) GetEvaluator 

func (x *PatchEvaluatorResponse) GetEvaluator() *Evaluator

func (*PatchEvaluatorResponse) ProtoMessage 

func (*PatchEvaluatorResponse) ProtoMessage()

func (*PatchEvaluatorResponse) ProtoReflect added in v1.2.14 

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

func (*PatchEvaluatorResponse) Reset 

func (x *PatchEvaluatorResponse) Reset()

func (*PatchEvaluatorResponse) String 

func (x *PatchEvaluatorResponse) String() string

type PatchTimerRequest 

type PatchTimerRequest struct {
	Timer *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchTimerRequest) Descriptor deprecated 

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

Deprecated: Use PatchTimerRequest.ProtoReflect.Descriptor instead.

func (*PatchTimerRequest) GetTimer 

func (x *PatchTimerRequest) GetTimer() *OpTimer

func (*PatchTimerRequest) ProtoMessage 

func (*PatchTimerRequest) ProtoMessage()

func (*PatchTimerRequest) ProtoReflect added in v1.2.14 

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

func (*PatchTimerRequest) Reset 

func (x *PatchTimerRequest) Reset()

func (*PatchTimerRequest) String 

func (x *PatchTimerRequest) String() string

type PatchTimerResponse 

type PatchTimerResponse struct {
	Timer *Timer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchTimerResponse) Descriptor deprecated 

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

Deprecated: Use PatchTimerResponse.ProtoReflect.Descriptor instead.

func (*PatchTimerResponse) GetTimer 

func (x *PatchTimerResponse) GetTimer() *Timer

func (*PatchTimerResponse) ProtoMessage 

func (*PatchTimerResponse) ProtoMessage()

func (*PatchTimerResponse) ProtoReflect added in v1.2.14 

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

func (*PatchTimerResponse) Reset 

func (x *PatchTimerResponse) Reset()

func (*PatchTimerResponse) String 

func (x *PatchTimerResponse) String() string

type QueryStorageByDeviceRequest 

type QueryStorageByDeviceRequest struct {
	Device      *deviced.OpDevice              `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Source      *OpResource                    `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Measurement *wrapperspb.StringValue        `protobuf:"bytes,3,opt,name=measurement,proto3" json:"measurement,omitempty"`
	RangeFrom   *timestamppb.Timestamp         `protobuf:"bytes,4,opt,name=range_from,json=rangeFrom,proto3" json:"range_from,omitempty"`
	RangeTo     *timestamppb.Timestamp         `protobuf:"bytes,5,opt,name=range_to,json=rangeTo,proto3" json:"range_to,omitempty"`
	QueryString *wrapperspb.StringValue        `protobuf:"bytes,6,opt,name=query_string,json=queryString,proto3" json:"query_string,omitempty"`
	Pagination  *pagination.OpPaginationOption `protobuf:"bytes,33,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryStorageByDeviceRequest) Descriptor deprecated 

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

Deprecated: Use QueryStorageByDeviceRequest.ProtoReflect.Descriptor instead.

func (*QueryStorageByDeviceRequest) GetDevice 

func (x *QueryStorageByDeviceRequest) GetDevice() *deviced.OpDevice

func (*QueryStorageByDeviceRequest) GetMeasurement 

func (x *QueryStorageByDeviceRequest) GetMeasurement() *wrapperspb.StringValue

func (*QueryStorageByDeviceRequest) GetPagination 

func (x *QueryStorageByDeviceRequest) GetPagination() *pagination.OpPaginationOption

func (*QueryStorageByDeviceRequest) GetQueryString 

func (x *QueryStorageByDeviceRequest) GetQueryString() *wrapperspb.StringValue

func (*QueryStorageByDeviceRequest) GetRangeFrom 

func (x *QueryStorageByDeviceRequest) GetRangeFrom() *timestamppb.Timestamp

func (*QueryStorageByDeviceRequest) GetRangeTo 

func (x *QueryStorageByDeviceRequest) GetRangeTo() *timestamppb.Timestamp

func (*QueryStorageByDeviceRequest) GetSource 

func (x *QueryStorageByDeviceRequest) GetSource() *OpResource

func (*QueryStorageByDeviceRequest) ProtoMessage 

func (*QueryStorageByDeviceRequest) ProtoMessage()

func (*QueryStorageByDeviceRequest) ProtoReflect added in v1.2.14 

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

func (*QueryStorageByDeviceRequest) Reset 

func (x *QueryStorageByDeviceRequest) Reset()

func (*QueryStorageByDeviceRequest) String 

func (x *QueryStorageByDeviceRequest) String() string

type QueryStorageByDeviceResponse 

type QueryStorageByDeviceResponse struct {
	Frames     []*deviced.Frame             `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
	Pagination *pagination.PaginationOption `protobuf:"bytes,33,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryStorageByDeviceResponse) Descriptor deprecated 

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

Deprecated: Use QueryStorageByDeviceResponse.ProtoReflect.Descriptor instead.

func (*QueryStorageByDeviceResponse) GetFrames 

func (x *QueryStorageByDeviceResponse) GetFrames() []*deviced.Frame

func (*QueryStorageByDeviceResponse) GetPagination 

func (x *QueryStorageByDeviceResponse) GetPagination() *pagination.PaginationOption

func (*QueryStorageByDeviceResponse) ProtoMessage 

func (*QueryStorageByDeviceResponse) ProtoMessage()

func (*QueryStorageByDeviceResponse) ProtoReflect added in v1.2.14 

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

func (*QueryStorageByDeviceResponse) Reset 

func (x *QueryStorageByDeviceResponse) Reset()

func (*QueryStorageByDeviceResponse) String 

func (x *QueryStorageByDeviceResponse) String() string

type RemoveConfigsFromTimerRequest 

type RemoveConfigsFromTimerRequest struct {
	Timer   *OpTimer            `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	Configs []*deviced.OpConfig `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveConfigsFromTimerRequest) Descriptor deprecated 

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

Deprecated: Use RemoveConfigsFromTimerRequest.ProtoReflect.Descriptor instead.

func (*RemoveConfigsFromTimerRequest) GetConfigs 

func (x *RemoveConfigsFromTimerRequest) GetConfigs() []*deviced.OpConfig

func (*RemoveConfigsFromTimerRequest) GetTimer 

func (x *RemoveConfigsFromTimerRequest) GetTimer() *OpTimer

func (*RemoveConfigsFromTimerRequest) ProtoMessage 

func (*RemoveConfigsFromTimerRequest) ProtoMessage()

func (*RemoveConfigsFromTimerRequest) ProtoReflect added in v1.2.14 

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

func (*RemoveConfigsFromTimerRequest) Reset 

func (x *RemoveConfigsFromTimerRequest) Reset()

func (*RemoveConfigsFromTimerRequest) String 

func (x *RemoveConfigsFromTimerRequest) String() string

type RemoveSourcesFromEvaluatorRequest 

type RemoveSourcesFromEvaluatorRequest struct {
	Sources   []*OpResource `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	Evaluator *OpEvaluator  `protobuf:"bytes,2,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveSourcesFromEvaluatorRequest) Descriptor deprecated 

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

Deprecated: Use RemoveSourcesFromEvaluatorRequest.ProtoReflect.Descriptor instead.

func (*RemoveSourcesFromEvaluatorRequest) GetEvaluator 

func (x *RemoveSourcesFromEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*RemoveSourcesFromEvaluatorRequest) GetSources 

func (x *RemoveSourcesFromEvaluatorRequest) GetSources() []*OpResource

func (*RemoveSourcesFromEvaluatorRequest) ProtoMessage 

func (*RemoveSourcesFromEvaluatorRequest) ProtoMessage()

func (*RemoveSourcesFromEvaluatorRequest) ProtoReflect added in v1.2.14 

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

func (*RemoveSourcesFromEvaluatorRequest) Reset 

func (x *RemoveSourcesFromEvaluatorRequest) Reset()

func (*RemoveSourcesFromEvaluatorRequest) String 

func (x *RemoveSourcesFromEvaluatorRequest) String() string

type Resource 

type Resource struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type string `protobuf:"bytes,8,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetId 

func (x *Resource) GetId() string

func (*Resource) GetType 

func (x *Resource) GetType() string

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect added in v1.2.14 

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

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type Task 

type Task struct {
	Id           string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	CurrentState *TaskState             `protobuf:"bytes,4,opt,name=current_state,json=currentState,proto3" json:"current_state,omitempty"`
	Source       *Resource              `protobuf:"bytes,8,opt,name=source,proto3" json:"source,omitempty"`
	States       []*TaskState           `protobuf:"bytes,9,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt 

func (x *Task) GetCreatedAt() *timestamppb.Timestamp

func (*Task) GetCurrentState 

func (x *Task) GetCurrentState() *TaskState

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetSource 

func (x *Task) GetSource() *Resource

func (*Task) GetStates 

func (x *Task) GetStates() []*TaskState

func (*Task) GetUpdatedAt 

func (x *Task) GetUpdatedAt() *timestamppb.Timestamp

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect added in v1.2.14 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskState 

type TaskState struct {
	At    *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	State state.TaskState        `protobuf:"varint,2,opt,name=state,proto3,enum=ai.metathings.constant.state.TaskState" json:"state,omitempty"`
	Tags  *structpb.Struct       `protobuf:"bytes,8,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskState) Descriptor deprecated 

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

Deprecated: Use TaskState.ProtoReflect.Descriptor instead.

func (*TaskState) GetAt 

func (x *TaskState) GetAt() *timestamppb.Timestamp

func (*TaskState) GetState 

func (x *TaskState) GetState() state.TaskState

func (*TaskState) GetTags 

func (x *TaskState) GetTags() *structpb.Struct

func (*TaskState) ProtoMessage 

func (*TaskState) ProtoMessage()

func (*TaskState) ProtoReflect added in v1.2.14 

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

func (*TaskState) Reset 

func (x *TaskState) Reset()

func (*TaskState) String 

func (x *TaskState) String() string

type Timer 

type Timer struct {
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias       string            `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description string            `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Schedule    string            `protobuf:"bytes,8,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Timezone    string            `protobuf:"bytes,9,opt,name=timezone,proto3" json:"timezone,omitempty"`
	Enabled     bool              `protobuf:"varint,10,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Configs     []*deviced.Config `protobuf:"bytes,11,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*Timer) Descriptor deprecated 

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

Deprecated: Use Timer.ProtoReflect.Descriptor instead.

func (*Timer) GetAlias 

func (x *Timer) GetAlias() string

func (*Timer) GetConfigs 

func (x *Timer) GetConfigs() []*deviced.Config

func (*Timer) GetDescription 

func (x *Timer) GetDescription() string

func (*Timer) GetEnabled 

func (x *Timer) GetEnabled() bool

func (*Timer) GetId 

func (x *Timer) GetId() string

func (*Timer) GetSchedule 

func (x *Timer) GetSchedule() string

func (*Timer) GetTimezone 

func (x *Timer) GetTimezone() string

func (*Timer) ProtoMessage 

func (*Timer) ProtoMessage()

func (*Timer) ProtoReflect added in v1.2.14 

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

func (*Timer) Reset 

func (x *Timer) Reset()

func (*Timer) String 

func (x *Timer) String() string

type UnimplementedEvaluatordServiceServer added in v1.2.14 

type UnimplementedEvaluatordServiceServer struct {
}

UnimplementedEvaluatordServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEvaluatordServiceServer) AddConfigsToTimer added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) AddConfigsToTimer(context.Context, *AddConfigsToTimerRequest) (*emptypb.Empty, error)

func (*UnimplementedEvaluatordServiceServer) AddSourcesToEvaluator added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) AddSourcesToEvaluator(context.Context, *AddSourcesToEvaluatorRequest) (*emptypb.Empty, error)

func (*UnimplementedEvaluatordServiceServer) CreateEvaluator added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) CreateEvaluator(context.Context, *CreateEvaluatorRequest) (*CreateEvaluatorResponse, error)

func (*UnimplementedEvaluatordServiceServer) CreateTimer added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) CreateTimer(context.Context, *CreateTimerRequest) (*CreateTimerResponse, error)

func (*UnimplementedEvaluatordServiceServer) DeleteEvaluator added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) DeleteEvaluator(context.Context, *DeleteEvaluatorRequest) (*emptypb.Empty, error)

func (*UnimplementedEvaluatordServiceServer) DeleteTimer added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) DeleteTimer(context.Context, *DeleteTimerRequest) (*emptypb.Empty, error)

func (*UnimplementedEvaluatordServiceServer) GetEvaluator added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) GetEvaluator(context.Context, *GetEvaluatorRequest) (*GetEvaluatorResponse, error)

func (*UnimplementedEvaluatordServiceServer) GetTask added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)

func (*UnimplementedEvaluatordServiceServer) GetTimer added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) GetTimer(context.Context, *GetTimerRequest) (*GetTimerResponse, error)

func (*UnimplementedEvaluatordServiceServer) ListEvaluators added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) ListEvaluators(context.Context, *ListEvaluatorsRequest) (*ListEvaluatorsResponse, error)

func (*UnimplementedEvaluatordServiceServer) ListEvaluatorsBySource added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) ListEvaluatorsBySource(context.Context, *ListEvaluatorsBySourceRequest) (*ListEvaluatorsBySourceResponse, error)

func (*UnimplementedEvaluatordServiceServer) ListTasksBySource added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) ListTasksBySource(context.Context, *ListTasksBySourceRequest) (*ListTasksBySourceResponse, error)

func (*UnimplementedEvaluatordServiceServer) ListTimers added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) ListTimers(context.Context, *ListTimersRequest) (*ListTimersResponse, error)

func (*UnimplementedEvaluatordServiceServer) PatchEvaluator added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) PatchEvaluator(context.Context, *PatchEvaluatorRequest) (*PatchEvaluatorResponse, error)

func (*UnimplementedEvaluatordServiceServer) PatchTimer added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) PatchTimer(context.Context, *PatchTimerRequest) (*PatchTimerResponse, error)

func (*UnimplementedEvaluatordServiceServer) QueryStorageByDevice added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) QueryStorageByDevice(context.Context, *QueryStorageByDeviceRequest) (*QueryStorageByDeviceResponse, error)

func (*UnimplementedEvaluatordServiceServer) RemoveConfigsFromTimer added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) RemoveConfigsFromTimer(context.Context, *RemoveConfigsFromTimerRequest) (*emptypb.Empty, error)

func (*UnimplementedEvaluatordServiceServer) RemoveSourcesFromEvaluator added in v1.2.14 

func (*UnimplementedEvaluatordServiceServer) RemoveSourcesFromEvaluator(context.Context, *RemoveSourcesFromEvaluatorRequest) (*emptypb.Empty, error)

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.