evaluatord

package
v1.3.0-alpha.8 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EvaluatordService_CreateEvaluator_FullMethodName            = "/ai.metathings.service.evaluatord.EvaluatordService/CreateEvaluator"
	EvaluatordService_DeleteEvaluator_FullMethodName            = "/ai.metathings.service.evaluatord.EvaluatordService/DeleteEvaluator"
	EvaluatordService_PatchEvaluator_FullMethodName             = "/ai.metathings.service.evaluatord.EvaluatordService/PatchEvaluator"
	EvaluatordService_GetEvaluator_FullMethodName               = "/ai.metathings.service.evaluatord.EvaluatordService/GetEvaluator"
	EvaluatordService_ListEvaluators_FullMethodName             = "/ai.metathings.service.evaluatord.EvaluatordService/ListEvaluators"
	EvaluatordService_AddSourcesToEvaluator_FullMethodName      = "/ai.metathings.service.evaluatord.EvaluatordService/AddSourcesToEvaluator"
	EvaluatordService_RemoveSourcesFromEvaluator_FullMethodName = "/ai.metathings.service.evaluatord.EvaluatordService/RemoveSourcesFromEvaluator"
	EvaluatordService_ListEvaluatorsBySource_FullMethodName     = "/ai.metathings.service.evaluatord.EvaluatordService/ListEvaluatorsBySource"
	EvaluatordService_ListTasksBySource_FullMethodName          = "/ai.metathings.service.evaluatord.EvaluatordService/ListTasksBySource"
	EvaluatordService_GetTask_FullMethodName                    = "/ai.metathings.service.evaluatord.EvaluatordService/GetTask"
	EvaluatordService_QueryStorageByDevice_FullMethodName       = "/ai.metathings.service.evaluatord.EvaluatordService/QueryStorageByDevice"
	EvaluatordService_CreateTimer_FullMethodName                = "/ai.metathings.service.evaluatord.EvaluatordService/CreateTimer"
	EvaluatordService_DeleteTimer_FullMethodName                = "/ai.metathings.service.evaluatord.EvaluatordService/DeleteTimer"
	EvaluatordService_PatchTimer_FullMethodName                 = "/ai.metathings.service.evaluatord.EvaluatordService/PatchTimer"
	EvaluatordService_GetTimer_FullMethodName                   = "/ai.metathings.service.evaluatord.EvaluatordService/GetTimer"
	EvaluatordService_ListTimers_FullMethodName                 = "/ai.metathings.service.evaluatord.EvaluatordService/ListTimers"
	EvaluatordService_AddConfigsToTimer_FullMethodName          = "/ai.metathings.service.evaluatord.EvaluatordService/AddConfigsToTimer"
	EvaluatordService_RemoveConfigsFromTimer_FullMethodName     = "/ai.metathings.service.evaluatord.EvaluatordService/RemoveConfigsFromTimer"
)

Variables

View Source 
var EvaluatordService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ai.metathings.service.evaluatord.EvaluatordService",
	HandlerType: (*EvaluatordServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateEvaluator",
			Handler:    _EvaluatordService_CreateEvaluator_Handler,
		},
		{
			MethodName: "DeleteEvaluator",
			Handler:    _EvaluatordService_DeleteEvaluator_Handler,
		},
		{
			MethodName: "PatchEvaluator",
			Handler:    _EvaluatordService_PatchEvaluator_Handler,
		},
		{
			MethodName: "GetEvaluator",
			Handler:    _EvaluatordService_GetEvaluator_Handler,
		},
		{
			MethodName: "ListEvaluators",
			Handler:    _EvaluatordService_ListEvaluators_Handler,
		},
		{
			MethodName: "AddSourcesToEvaluator",
			Handler:    _EvaluatordService_AddSourcesToEvaluator_Handler,
		},
		{
			MethodName: "RemoveSourcesFromEvaluator",
			Handler:    _EvaluatordService_RemoveSourcesFromEvaluator_Handler,
		},
		{
			MethodName: "ListEvaluatorsBySource",
			Handler:    _EvaluatordService_ListEvaluatorsBySource_Handler,
		},
		{
			MethodName: "ListTasksBySource",
			Handler:    _EvaluatordService_ListTasksBySource_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _EvaluatordService_GetTask_Handler,
		},
		{
			MethodName: "QueryStorageByDevice",
			Handler:    _EvaluatordService_QueryStorageByDevice_Handler,
		},
		{
			MethodName: "CreateTimer",
			Handler:    _EvaluatordService_CreateTimer_Handler,
		},
		{
			MethodName: "DeleteTimer",
			Handler:    _EvaluatordService_DeleteTimer_Handler,
		},
		{
			MethodName: "PatchTimer",
			Handler:    _EvaluatordService_PatchTimer_Handler,
		},
		{
			MethodName: "GetTimer",
			Handler:    _EvaluatordService_GetTimer_Handler,
		},
		{
			MethodName: "ListTimers",
			Handler:    _EvaluatordService_ListTimers_Handler,
		},
		{
			MethodName: "AddConfigsToTimer",
			Handler:    _EvaluatordService_AddConfigsToTimer_Handler,
		},
		{
			MethodName: "RemoveConfigsFromTimer",
			Handler:    _EvaluatordService_RemoveConfigsFromTimer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

EvaluatordService_ServiceDesc is the grpc.ServiceDesc for EvaluatordService 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_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.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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)
	// contains filtered or unexported methods
}

EvaluatordServiceServer is the server API for EvaluatordService service. All implementations must embed UnimplementedEvaluatordServiceServer for forward compatibility.

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 must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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)

type UnsafeEvaluatordServiceServer 

type UnsafeEvaluatordServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeEvaluatordServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EvaluatordServiceServer will result in compilation errors.

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.