evaluatord

package
v1.2.7 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2020 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEvaluatordServiceServer 

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

Types

type AddConfigsToTimerRequest added in v1.1.28 

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*AddConfigsToTimerRequest) Descriptor added in v1.1.28 

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

func (*AddConfigsToTimerRequest) GetConfigs added in v1.1.28 

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

func (*AddConfigsToTimerRequest) GetTimer added in v1.1.28 

func (m *AddConfigsToTimerRequest) GetTimer() *OpTimer

func (*AddConfigsToTimerRequest) ProtoMessage added in v1.1.28 

func (*AddConfigsToTimerRequest) ProtoMessage()

func (*AddConfigsToTimerRequest) Reset added in v1.1.28 

func (m *AddConfigsToTimerRequest) Reset()

func (*AddConfigsToTimerRequest) String added in v1.1.28 

func (m *AddConfigsToTimerRequest) String() string

func (*AddConfigsToTimerRequest) Validate added in v1.1.28 

func (this *AddConfigsToTimerRequest) Validate() error

func (*AddConfigsToTimerRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *AddConfigsToTimerRequest) XXX_DiscardUnknown()

func (*AddConfigsToTimerRequest) XXX_Marshal added in v1.1.28 

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

func (*AddConfigsToTimerRequest) XXX_Merge added in v1.1.28 

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

func (*AddConfigsToTimerRequest) XXX_Size added in v1.1.28 

func (m *AddConfigsToTimerRequest) XXX_Size() int

func (*AddConfigsToTimerRequest) XXX_Unmarshal added in v1.1.28 

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

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*AddSourcesToEvaluatorRequest) Descriptor 

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

func (*AddSourcesToEvaluatorRequest) GetEvaluator 

func (m *AddSourcesToEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*AddSourcesToEvaluatorRequest) GetSources 

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

func (*AddSourcesToEvaluatorRequest) ProtoMessage 

func (*AddSourcesToEvaluatorRequest) ProtoMessage()

func (*AddSourcesToEvaluatorRequest) Reset 

func (m *AddSourcesToEvaluatorRequest) Reset()

func (*AddSourcesToEvaluatorRequest) String 

func (m *AddSourcesToEvaluatorRequest) String() string

func (*AddSourcesToEvaluatorRequest) Validate 

func (this *AddSourcesToEvaluatorRequest) Validate() error

func (*AddSourcesToEvaluatorRequest) XXX_DiscardUnknown 

func (m *AddSourcesToEvaluatorRequest) XXX_DiscardUnknown()

func (*AddSourcesToEvaluatorRequest) XXX_Marshal 

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

func (*AddSourcesToEvaluatorRequest) XXX_Merge 

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

func (*AddSourcesToEvaluatorRequest) XXX_Size 

func (m *AddSourcesToEvaluatorRequest) XXX_Size() int

func (*AddSourcesToEvaluatorRequest) XXX_Unmarshal 

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

type CreateEvaluatorRequest 

type CreateEvaluatorRequest struct {
	Evaluator            *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateEvaluatorRequest) Descriptor 

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

func (*CreateEvaluatorRequest) GetEvaluator 

func (m *CreateEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*CreateEvaluatorRequest) ProtoMessage 

func (*CreateEvaluatorRequest) ProtoMessage()

func (*CreateEvaluatorRequest) Reset 

func (m *CreateEvaluatorRequest) Reset()

func (*CreateEvaluatorRequest) String 

func (m *CreateEvaluatorRequest) String() string

func (*CreateEvaluatorRequest) Validate 

func (this *CreateEvaluatorRequest) Validate() error

func (*CreateEvaluatorRequest) XXX_DiscardUnknown 

func (m *CreateEvaluatorRequest) XXX_DiscardUnknown()

func (*CreateEvaluatorRequest) XXX_Marshal 

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

func (*CreateEvaluatorRequest) XXX_Merge 

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

func (*CreateEvaluatorRequest) XXX_Size 

func (m *CreateEvaluatorRequest) XXX_Size() int

func (*CreateEvaluatorRequest) XXX_Unmarshal 

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

type CreateEvaluatorResponse 

type CreateEvaluatorResponse struct {
	Evaluator            *Evaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CreateEvaluatorResponse) Descriptor 

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

func (*CreateEvaluatorResponse) GetEvaluator 

func (m *CreateEvaluatorResponse) GetEvaluator() *Evaluator

func (*CreateEvaluatorResponse) ProtoMessage 

func (*CreateEvaluatorResponse) ProtoMessage()

func (*CreateEvaluatorResponse) Reset 

func (m *CreateEvaluatorResponse) Reset()

func (*CreateEvaluatorResponse) String 

func (m *CreateEvaluatorResponse) String() string

func (*CreateEvaluatorResponse) Validate 

func (this *CreateEvaluatorResponse) Validate() error

func (*CreateEvaluatorResponse) XXX_DiscardUnknown 

func (m *CreateEvaluatorResponse) XXX_DiscardUnknown()

func (*CreateEvaluatorResponse) XXX_Marshal 

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

func (*CreateEvaluatorResponse) XXX_Merge 

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

func (*CreateEvaluatorResponse) XXX_Size 

func (m *CreateEvaluatorResponse) XXX_Size() int

func (*CreateEvaluatorResponse) XXX_Unmarshal 

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

type CreateTimerRequest added in v1.1.28 

type CreateTimerRequest struct {
	Timer                *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTimerRequest) Descriptor added in v1.1.28 

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

func (*CreateTimerRequest) GetTimer added in v1.1.28 

func (m *CreateTimerRequest) GetTimer() *OpTimer

func (*CreateTimerRequest) ProtoMessage added in v1.1.28 

func (*CreateTimerRequest) ProtoMessage()

func (*CreateTimerRequest) Reset added in v1.1.28 

func (m *CreateTimerRequest) Reset()

func (*CreateTimerRequest) String added in v1.1.28 

func (m *CreateTimerRequest) String() string

func (*CreateTimerRequest) Validate added in v1.1.28 

func (this *CreateTimerRequest) Validate() error

func (*CreateTimerRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *CreateTimerRequest) XXX_DiscardUnknown()

func (*CreateTimerRequest) XXX_Marshal added in v1.1.28 

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

func (*CreateTimerRequest) XXX_Merge added in v1.1.28 

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

func (*CreateTimerRequest) XXX_Size added in v1.1.28 

func (m *CreateTimerRequest) XXX_Size() int

func (*CreateTimerRequest) XXX_Unmarshal added in v1.1.28 

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

type CreateTimerResponse added in v1.1.28 

type CreateTimerResponse struct {
	Timer                *Timer   `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTimerResponse) Descriptor added in v1.1.28 

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

func (*CreateTimerResponse) GetTimer added in v1.1.28 

func (m *CreateTimerResponse) GetTimer() *Timer

func (*CreateTimerResponse) ProtoMessage added in v1.1.28 

func (*CreateTimerResponse) ProtoMessage()

func (*CreateTimerResponse) Reset added in v1.1.28 

func (m *CreateTimerResponse) Reset()

func (*CreateTimerResponse) String added in v1.1.28 

func (m *CreateTimerResponse) String() string

func (*CreateTimerResponse) Validate added in v1.1.28 

func (this *CreateTimerResponse) Validate() error

func (*CreateTimerResponse) XXX_DiscardUnknown added in v1.1.28 

func (m *CreateTimerResponse) XXX_DiscardUnknown()

func (*CreateTimerResponse) XXX_Marshal added in v1.1.28 

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

func (*CreateTimerResponse) XXX_Merge added in v1.1.28 

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

func (*CreateTimerResponse) XXX_Size added in v1.1.28 

func (m *CreateTimerResponse) XXX_Size() int

func (*CreateTimerResponse) XXX_Unmarshal added in v1.1.28 

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

type DeleteEvaluatorRequest 

type DeleteEvaluatorRequest struct {
	Evaluator            *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteEvaluatorRequest) Descriptor 

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

func (*DeleteEvaluatorRequest) GetEvaluator 

func (m *DeleteEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*DeleteEvaluatorRequest) ProtoMessage 

func (*DeleteEvaluatorRequest) ProtoMessage()

func (*DeleteEvaluatorRequest) Reset 

func (m *DeleteEvaluatorRequest) Reset()

func (*DeleteEvaluatorRequest) String 

func (m *DeleteEvaluatorRequest) String() string

func (*DeleteEvaluatorRequest) Validate 

func (this *DeleteEvaluatorRequest) Validate() error

func (*DeleteEvaluatorRequest) XXX_DiscardUnknown 

func (m *DeleteEvaluatorRequest) XXX_DiscardUnknown()

func (*DeleteEvaluatorRequest) XXX_Marshal 

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

func (*DeleteEvaluatorRequest) XXX_Merge 

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

func (*DeleteEvaluatorRequest) XXX_Size 

func (m *DeleteEvaluatorRequest) XXX_Size() int

func (*DeleteEvaluatorRequest) XXX_Unmarshal 

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

type DeleteTimerRequest added in v1.1.28 

type DeleteTimerRequest struct {
	Timer                *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTimerRequest) Descriptor added in v1.1.28 

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

func (*DeleteTimerRequest) GetTimer added in v1.1.28 

func (m *DeleteTimerRequest) GetTimer() *OpTimer

func (*DeleteTimerRequest) ProtoMessage added in v1.1.28 

func (*DeleteTimerRequest) ProtoMessage()

func (*DeleteTimerRequest) Reset added in v1.1.28 

func (m *DeleteTimerRequest) Reset()

func (*DeleteTimerRequest) String added in v1.1.28 

func (m *DeleteTimerRequest) String() string

func (*DeleteTimerRequest) Validate added in v1.1.28 

func (this *DeleteTimerRequest) Validate() error

func (*DeleteTimerRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *DeleteTimerRequest) XXX_DiscardUnknown()

func (*DeleteTimerRequest) XXX_Marshal added in v1.1.28 

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

func (*DeleteTimerRequest) XXX_Merge added in v1.1.28 

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

func (*DeleteTimerRequest) XXX_Size added in v1.1.28 

func (m *DeleteTimerRequest) XXX_Size() int

func (*DeleteTimerRequest) XXX_Unmarshal added in v1.1.28 

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

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               *_struct.Struct `protobuf:"bytes,11,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Evaluator) Descriptor 

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

func (*Evaluator) GetAlias 

func (m *Evaluator) GetAlias() string

func (*Evaluator) GetConfig 

func (m *Evaluator) GetConfig() *_struct.Struct

func (*Evaluator) GetDescription 

func (m *Evaluator) GetDescription() string

func (*Evaluator) GetId 

func (m *Evaluator) GetId() string

func (*Evaluator) GetOperator 

func (m *Evaluator) GetOperator() *Operator

func (*Evaluator) GetSources 

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

func (*Evaluator) ProtoMessage 

func (*Evaluator) ProtoMessage()

func (*Evaluator) Reset 

func (m *Evaluator) Reset()

func (*Evaluator) String 

func (m *Evaluator) String() string

func (*Evaluator) Validate 

func (this *Evaluator) Validate() error

func (*Evaluator) XXX_DiscardUnknown 

func (m *Evaluator) XXX_DiscardUnknown()

func (*Evaluator) XXX_Marshal 

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

func (*Evaluator) XXX_Merge 

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

func (*Evaluator) XXX_Size 

func (m *Evaluator) XXX_Size() int

func (*Evaluator) XXX_Unmarshal 

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

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) (*empty.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) (*empty.Empty, error)
	RemoveSourcesFromEvaluator(ctx context.Context, in *RemoveSourcesFromEvaluatorRequest, opts ...grpc.CallOption) (*empty.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) (*empty.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) (*empty.Empty, error)
	RemoveConfigsFromTimer(ctx context.Context, in *RemoveConfigsFromTimerRequest, opts ...grpc.CallOption) (*empty.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.ClientConn) EvaluatordServiceClient

type EvaluatordServiceServer 

type EvaluatordServiceServer interface {
	CreateEvaluator(context.Context, *CreateEvaluatorRequest) (*CreateEvaluatorResponse, error)
	DeleteEvaluator(context.Context, *DeleteEvaluatorRequest) (*empty.Empty, error)
	PatchEvaluator(context.Context, *PatchEvaluatorRequest) (*PatchEvaluatorResponse, error)
	GetEvaluator(context.Context, *GetEvaluatorRequest) (*GetEvaluatorResponse, error)
	ListEvaluators(context.Context, *ListEvaluatorsRequest) (*ListEvaluatorsResponse, error)
	AddSourcesToEvaluator(context.Context, *AddSourcesToEvaluatorRequest) (*empty.Empty, error)
	RemoveSourcesFromEvaluator(context.Context, *RemoveSourcesFromEvaluatorRequest) (*empty.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) (*empty.Empty, error)
	PatchTimer(context.Context, *PatchTimerRequest) (*PatchTimerResponse, error)
	GetTimer(context.Context, *GetTimerRequest) (*GetTimerResponse, error)
	ListTimers(context.Context, *ListTimersRequest) (*ListTimersResponse, error)
	AddConfigsToTimer(context.Context, *AddConfigsToTimerRequest) (*empty.Empty, error)
	RemoveConfigsFromTimer(context.Context, *RemoveConfigsFromTimerRequest) (*empty.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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetEvaluatorRequest) Descriptor 

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

func (*GetEvaluatorRequest) GetEvaluator 

func (m *GetEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*GetEvaluatorRequest) ProtoMessage 

func (*GetEvaluatorRequest) ProtoMessage()

func (*GetEvaluatorRequest) Reset 

func (m *GetEvaluatorRequest) Reset()

func (*GetEvaluatorRequest) String 

func (m *GetEvaluatorRequest) String() string

func (*GetEvaluatorRequest) Validate 

func (this *GetEvaluatorRequest) Validate() error

func (*GetEvaluatorRequest) XXX_DiscardUnknown 

func (m *GetEvaluatorRequest) XXX_DiscardUnknown()

func (*GetEvaluatorRequest) XXX_Marshal 

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

func (*GetEvaluatorRequest) XXX_Merge 

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

func (*GetEvaluatorRequest) XXX_Size 

func (m *GetEvaluatorRequest) XXX_Size() int

func (*GetEvaluatorRequest) XXX_Unmarshal 

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

type GetEvaluatorResponse 

type GetEvaluatorResponse struct {
	Evaluator            *Evaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetEvaluatorResponse) Descriptor 

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

func (*GetEvaluatorResponse) GetEvaluator 

func (m *GetEvaluatorResponse) GetEvaluator() *Evaluator

func (*GetEvaluatorResponse) ProtoMessage 

func (*GetEvaluatorResponse) ProtoMessage()

func (*GetEvaluatorResponse) Reset 

func (m *GetEvaluatorResponse) Reset()

func (*GetEvaluatorResponse) String 

func (m *GetEvaluatorResponse) String() string

func (*GetEvaluatorResponse) Validate 

func (this *GetEvaluatorResponse) Validate() error

func (*GetEvaluatorResponse) XXX_DiscardUnknown 

func (m *GetEvaluatorResponse) XXX_DiscardUnknown()

func (*GetEvaluatorResponse) XXX_Marshal 

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

func (*GetEvaluatorResponse) XXX_Merge 

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

func (*GetEvaluatorResponse) XXX_Size 

func (m *GetEvaluatorResponse) XXX_Size() int

func (*GetEvaluatorResponse) XXX_Unmarshal 

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

type GetTaskRequest added in v1.1.28 

type GetTaskRequest struct {
	Task                 *OpTask  `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTaskRequest) Descriptor added in v1.1.28 

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

func (*GetTaskRequest) GetTask added in v1.1.28 

func (m *GetTaskRequest) GetTask() *OpTask

func (*GetTaskRequest) ProtoMessage added in v1.1.28 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) Reset added in v1.1.28 

func (m *GetTaskRequest) Reset()

func (*GetTaskRequest) String added in v1.1.28 

func (m *GetTaskRequest) String() string

func (*GetTaskRequest) Validate added in v1.1.28 

func (this *GetTaskRequest) Validate() error

func (*GetTaskRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *GetTaskRequest) XXX_DiscardUnknown()

func (*GetTaskRequest) XXX_Marshal added in v1.1.28 

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

func (*GetTaskRequest) XXX_Merge added in v1.1.28 

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

func (*GetTaskRequest) XXX_Size added in v1.1.28 

func (m *GetTaskRequest) XXX_Size() int

func (*GetTaskRequest) XXX_Unmarshal added in v1.1.28 

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

type GetTaskResponse added in v1.1.28 

type GetTaskResponse struct {
	Task                 *Task    `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTaskResponse) Descriptor added in v1.1.28 

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

func (*GetTaskResponse) GetTask added in v1.1.28 

func (m *GetTaskResponse) GetTask() *Task

func (*GetTaskResponse) ProtoMessage added in v1.1.28 

func (*GetTaskResponse) ProtoMessage()

func (*GetTaskResponse) Reset added in v1.1.28 

func (m *GetTaskResponse) Reset()

func (*GetTaskResponse) String added in v1.1.28 

func (m *GetTaskResponse) String() string

func (*GetTaskResponse) Validate added in v1.1.28 

func (this *GetTaskResponse) Validate() error

func (*GetTaskResponse) XXX_DiscardUnknown added in v1.1.28 

func (m *GetTaskResponse) XXX_DiscardUnknown()

func (*GetTaskResponse) XXX_Marshal added in v1.1.28 

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

func (*GetTaskResponse) XXX_Merge added in v1.1.28 

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

func (*GetTaskResponse) XXX_Size added in v1.1.28 

func (m *GetTaskResponse) XXX_Size() int

func (*GetTaskResponse) XXX_Unmarshal added in v1.1.28 

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

type GetTimerRequest added in v1.1.28 

type GetTimerRequest struct {
	Timer                *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTimerRequest) Descriptor added in v1.1.28 

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

func (*GetTimerRequest) GetTimer added in v1.1.28 

func (m *GetTimerRequest) GetTimer() *OpTimer

func (*GetTimerRequest) ProtoMessage added in v1.1.28 

func (*GetTimerRequest) ProtoMessage()

func (*GetTimerRequest) Reset added in v1.1.28 

func (m *GetTimerRequest) Reset()

func (*GetTimerRequest) String added in v1.1.28 

func (m *GetTimerRequest) String() string

func (*GetTimerRequest) Validate added in v1.1.28 

func (this *GetTimerRequest) Validate() error

func (*GetTimerRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *GetTimerRequest) XXX_DiscardUnknown()

func (*GetTimerRequest) XXX_Marshal added in v1.1.28 

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

func (*GetTimerRequest) XXX_Merge added in v1.1.28 

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

func (*GetTimerRequest) XXX_Size added in v1.1.28 

func (m *GetTimerRequest) XXX_Size() int

func (*GetTimerRequest) XXX_Unmarshal added in v1.1.28 

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

type GetTimerResponse added in v1.1.28 

type GetTimerResponse struct {
	Timer                *Timer   `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTimerResponse) Descriptor added in v1.1.28 

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

func (*GetTimerResponse) GetTimer added in v1.1.28 

func (m *GetTimerResponse) GetTimer() *Timer

func (*GetTimerResponse) ProtoMessage added in v1.1.28 

func (*GetTimerResponse) ProtoMessage()

func (*GetTimerResponse) Reset added in v1.1.28 

func (m *GetTimerResponse) Reset()

func (*GetTimerResponse) String added in v1.1.28 

func (m *GetTimerResponse) String() string

func (*GetTimerResponse) Validate added in v1.1.28 

func (this *GetTimerResponse) Validate() error

func (*GetTimerResponse) XXX_DiscardUnknown added in v1.1.28 

func (m *GetTimerResponse) XXX_DiscardUnknown()

func (*GetTimerResponse) XXX_Marshal added in v1.1.28 

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

func (*GetTimerResponse) XXX_Merge added in v1.1.28 

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

func (*GetTimerResponse) XXX_Size added in v1.1.28 

func (m *GetTimerResponse) XXX_Size() int

func (*GetTimerResponse) XXX_Unmarshal added in v1.1.28 

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

type ListEvaluatorsBySourceRequest 

type ListEvaluatorsBySourceRequest struct {
	Source               *OpResource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ListEvaluatorsBySourceRequest) Descriptor 

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

func (*ListEvaluatorsBySourceRequest) GetSource 

func (m *ListEvaluatorsBySourceRequest) GetSource() *OpResource

func (*ListEvaluatorsBySourceRequest) ProtoMessage 

func (*ListEvaluatorsBySourceRequest) ProtoMessage()

func (*ListEvaluatorsBySourceRequest) Reset 

func (m *ListEvaluatorsBySourceRequest) Reset()

func (*ListEvaluatorsBySourceRequest) String 

func (m *ListEvaluatorsBySourceRequest) String() string

func (*ListEvaluatorsBySourceRequest) Validate 

func (this *ListEvaluatorsBySourceRequest) Validate() error

func (*ListEvaluatorsBySourceRequest) XXX_DiscardUnknown 

func (m *ListEvaluatorsBySourceRequest) XXX_DiscardUnknown()

func (*ListEvaluatorsBySourceRequest) XXX_Marshal 

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

func (*ListEvaluatorsBySourceRequest) XXX_Merge 

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

func (*ListEvaluatorsBySourceRequest) XXX_Size 

func (m *ListEvaluatorsBySourceRequest) XXX_Size() int

func (*ListEvaluatorsBySourceRequest) XXX_Unmarshal 

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

type ListEvaluatorsBySourceResponse 

type ListEvaluatorsBySourceResponse struct {
	Evaluators           []*Evaluator `protobuf:"bytes,1,rep,name=evaluators,proto3" json:"evaluators,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListEvaluatorsBySourceResponse) Descriptor 

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

func (*ListEvaluatorsBySourceResponse) GetEvaluators 

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

func (*ListEvaluatorsBySourceResponse) ProtoMessage 

func (*ListEvaluatorsBySourceResponse) ProtoMessage()

func (*ListEvaluatorsBySourceResponse) Reset 

func (m *ListEvaluatorsBySourceResponse) Reset()

func (*ListEvaluatorsBySourceResponse) String 

func (m *ListEvaluatorsBySourceResponse) String() string

func (*ListEvaluatorsBySourceResponse) Validate 

func (this *ListEvaluatorsBySourceResponse) Validate() error

func (*ListEvaluatorsBySourceResponse) XXX_DiscardUnknown 

func (m *ListEvaluatorsBySourceResponse) XXX_DiscardUnknown()

func (*ListEvaluatorsBySourceResponse) XXX_Marshal 

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

func (*ListEvaluatorsBySourceResponse) XXX_Merge 

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

func (*ListEvaluatorsBySourceResponse) XXX_Size 

func (m *ListEvaluatorsBySourceResponse) XXX_Size() int

func (*ListEvaluatorsBySourceResponse) XXX_Unmarshal 

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

type ListEvaluatorsRequest 

type ListEvaluatorsRequest struct {
	Evaluator            *OpEvaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListEvaluatorsRequest) Descriptor 

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

func (*ListEvaluatorsRequest) GetEvaluator 

func (m *ListEvaluatorsRequest) GetEvaluator() *OpEvaluator

func (*ListEvaluatorsRequest) ProtoMessage 

func (*ListEvaluatorsRequest) ProtoMessage()

func (*ListEvaluatorsRequest) Reset 

func (m *ListEvaluatorsRequest) Reset()

func (*ListEvaluatorsRequest) String 

func (m *ListEvaluatorsRequest) String() string

func (*ListEvaluatorsRequest) Validate 

func (this *ListEvaluatorsRequest) Validate() error

func (*ListEvaluatorsRequest) XXX_DiscardUnknown 

func (m *ListEvaluatorsRequest) XXX_DiscardUnknown()

func (*ListEvaluatorsRequest) XXX_Marshal 

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

func (*ListEvaluatorsRequest) XXX_Merge 

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

func (*ListEvaluatorsRequest) XXX_Size 

func (m *ListEvaluatorsRequest) XXX_Size() int

func (*ListEvaluatorsRequest) XXX_Unmarshal 

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

type ListEvaluatorsResponse 

type ListEvaluatorsResponse struct {
	Evaluators           []*Evaluator `protobuf:"bytes,1,rep,name=evaluators,proto3" json:"evaluators,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListEvaluatorsResponse) Descriptor 

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

func (*ListEvaluatorsResponse) GetEvaluators 

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

func (*ListEvaluatorsResponse) ProtoMessage 

func (*ListEvaluatorsResponse) ProtoMessage()

func (*ListEvaluatorsResponse) Reset 

func (m *ListEvaluatorsResponse) Reset()

func (*ListEvaluatorsResponse) String 

func (m *ListEvaluatorsResponse) String() string

func (*ListEvaluatorsResponse) Validate 

func (this *ListEvaluatorsResponse) Validate() error

func (*ListEvaluatorsResponse) XXX_DiscardUnknown 

func (m *ListEvaluatorsResponse) XXX_DiscardUnknown()

func (*ListEvaluatorsResponse) XXX_Marshal 

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

func (*ListEvaluatorsResponse) XXX_Merge 

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

func (*ListEvaluatorsResponse) XXX_Size 

func (m *ListEvaluatorsResponse) XXX_Size() int

func (*ListEvaluatorsResponse) XXX_Unmarshal 

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

type ListTasksBySourceRequest added in v1.1.28 

type ListTasksBySourceRequest struct {
	Source               *OpResource          `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	RangeFrom            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=range_from,json=rangeFrom,proto3" json:"range_from,omitempty"`
	RangeTo              *timestamp.Timestamp `protobuf:"bytes,3,opt,name=range_to,json=rangeTo,proto3" json:"range_to,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListTasksBySourceRequest) Descriptor added in v1.1.28 

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

func (*ListTasksBySourceRequest) GetRangeFrom added in v1.1.28 

func (m *ListTasksBySourceRequest) GetRangeFrom() *timestamp.Timestamp

func (*ListTasksBySourceRequest) GetRangeTo added in v1.1.28 

func (m *ListTasksBySourceRequest) GetRangeTo() *timestamp.Timestamp

func (*ListTasksBySourceRequest) GetSource added in v1.1.28 

func (m *ListTasksBySourceRequest) GetSource() *OpResource

func (*ListTasksBySourceRequest) ProtoMessage added in v1.1.28 

func (*ListTasksBySourceRequest) ProtoMessage()

func (*ListTasksBySourceRequest) Reset added in v1.1.28 

func (m *ListTasksBySourceRequest) Reset()

func (*ListTasksBySourceRequest) String added in v1.1.28 

func (m *ListTasksBySourceRequest) String() string

func (*ListTasksBySourceRequest) Validate added in v1.1.28 

func (this *ListTasksBySourceRequest) Validate() error

func (*ListTasksBySourceRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *ListTasksBySourceRequest) XXX_DiscardUnknown()

func (*ListTasksBySourceRequest) XXX_Marshal added in v1.1.28 

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

func (*ListTasksBySourceRequest) XXX_Merge added in v1.1.28 

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

func (*ListTasksBySourceRequest) XXX_Size added in v1.1.28 

func (m *ListTasksBySourceRequest) XXX_Size() int

func (*ListTasksBySourceRequest) XXX_Unmarshal added in v1.1.28 

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

type ListTasksBySourceResponse added in v1.1.28 

type ListTasksBySourceResponse struct {
	Tasks                []*Task  `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTasksBySourceResponse) Descriptor added in v1.1.28 

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

func (*ListTasksBySourceResponse) GetTasks added in v1.1.28 

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

func (*ListTasksBySourceResponse) ProtoMessage added in v1.1.28 

func (*ListTasksBySourceResponse) ProtoMessage()

func (*ListTasksBySourceResponse) Reset added in v1.1.28 

func (m *ListTasksBySourceResponse) Reset()

func (*ListTasksBySourceResponse) String added in v1.1.28 

func (m *ListTasksBySourceResponse) String() string

func (*ListTasksBySourceResponse) Validate added in v1.1.28 

func (this *ListTasksBySourceResponse) Validate() error

func (*ListTasksBySourceResponse) XXX_DiscardUnknown added in v1.1.28 

func (m *ListTasksBySourceResponse) XXX_DiscardUnknown()

func (*ListTasksBySourceResponse) XXX_Marshal added in v1.1.28 

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

func (*ListTasksBySourceResponse) XXX_Merge added in v1.1.28 

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

func (*ListTasksBySourceResponse) XXX_Size added in v1.1.28 

func (m *ListTasksBySourceResponse) XXX_Size() int

func (*ListTasksBySourceResponse) XXX_Unmarshal added in v1.1.28 

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

type ListTimersRequest added in v1.1.28 

type ListTimersRequest struct {
	Timer                *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTimersRequest) Descriptor added in v1.1.28 

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

func (*ListTimersRequest) GetTimer added in v1.1.28 

func (m *ListTimersRequest) GetTimer() *OpTimer

func (*ListTimersRequest) ProtoMessage added in v1.1.28 

func (*ListTimersRequest) ProtoMessage()

func (*ListTimersRequest) Reset added in v1.1.28 

func (m *ListTimersRequest) Reset()

func (*ListTimersRequest) String added in v1.1.28 

func (m *ListTimersRequest) String() string

func (*ListTimersRequest) Validate added in v1.1.28 

func (this *ListTimersRequest) Validate() error

func (*ListTimersRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *ListTimersRequest) XXX_DiscardUnknown()

func (*ListTimersRequest) XXX_Marshal added in v1.1.28 

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

func (*ListTimersRequest) XXX_Merge added in v1.1.28 

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

func (*ListTimersRequest) XXX_Size added in v1.1.28 

func (m *ListTimersRequest) XXX_Size() int

func (*ListTimersRequest) XXX_Unmarshal added in v1.1.28 

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

type ListTimersResponse added in v1.1.28 

type ListTimersResponse struct {
	Timers               []*Timer `protobuf:"bytes,1,rep,name=timers,proto3" json:"timers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTimersResponse) Descriptor added in v1.1.28 

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

func (*ListTimersResponse) GetTimers added in v1.1.28 

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

func (*ListTimersResponse) ProtoMessage added in v1.1.28 

func (*ListTimersResponse) ProtoMessage()

func (*ListTimersResponse) Reset added in v1.1.28 

func (m *ListTimersResponse) Reset()

func (*ListTimersResponse) String added in v1.1.28 

func (m *ListTimersResponse) String() string

func (*ListTimersResponse) Validate added in v1.1.28 

func (this *ListTimersResponse) Validate() error

func (*ListTimersResponse) XXX_DiscardUnknown added in v1.1.28 

func (m *ListTimersResponse) XXX_DiscardUnknown()

func (*ListTimersResponse) XXX_Marshal added in v1.1.28 

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

func (*ListTimersResponse) XXX_Merge added in v1.1.28 

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

func (*ListTimersResponse) XXX_Size added in v1.1.28 

func (m *ListTimersResponse) XXX_Size() int

func (*ListTimersResponse) XXX_Unmarshal added in v1.1.28 

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

type LuaDescriptor 

type LuaDescriptor struct {
	Code                 string   `protobuf:"bytes,8,opt,name=code,proto3" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LuaDescriptor) Descriptor 

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

func (*LuaDescriptor) GetCode 

func (m *LuaDescriptor) GetCode() string

func (*LuaDescriptor) ProtoMessage 

func (*LuaDescriptor) ProtoMessage()

func (*LuaDescriptor) Reset 

func (m *LuaDescriptor) Reset()

func (*LuaDescriptor) String 

func (m *LuaDescriptor) String() string

func (*LuaDescriptor) Validate 

func (this *LuaDescriptor) Validate() error

func (*LuaDescriptor) XXX_DiscardUnknown 

func (m *LuaDescriptor) XXX_DiscardUnknown()

func (*LuaDescriptor) XXX_Marshal 

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

func (*LuaDescriptor) XXX_Merge 

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

func (*LuaDescriptor) XXX_Size 

func (m *LuaDescriptor) XXX_Size() int

func (*LuaDescriptor) XXX_Unmarshal 

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

type OpEvaluator 

type OpEvaluator struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description          *wrappers.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               *_struct.Struct       `protobuf:"bytes,11,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpEvaluator) Descriptor 

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

func (*OpEvaluator) GetAlias 

func (m *OpEvaluator) GetAlias() *wrappers.StringValue

func (*OpEvaluator) GetConfig 

func (m *OpEvaluator) GetConfig() *_struct.Struct

func (*OpEvaluator) GetDescription 

func (m *OpEvaluator) GetDescription() *wrappers.StringValue

func (*OpEvaluator) GetId 

func (m *OpEvaluator) GetId() *wrappers.StringValue

func (*OpEvaluator) GetOperator 

func (m *OpEvaluator) GetOperator() *OpOperator

func (*OpEvaluator) GetSources 

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

func (*OpEvaluator) ProtoMessage 

func (*OpEvaluator) ProtoMessage()

func (*OpEvaluator) Reset 

func (m *OpEvaluator) Reset()

func (*OpEvaluator) String 

func (m *OpEvaluator) String() string

func (*OpEvaluator) Validate 

func (this *OpEvaluator) Validate() error

func (*OpEvaluator) XXX_DiscardUnknown 

func (m *OpEvaluator) XXX_DiscardUnknown()

func (*OpEvaluator) XXX_Marshal 

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

func (*OpEvaluator) XXX_Merge 

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

func (*OpEvaluator) XXX_Size 

func (m *OpEvaluator) XXX_Size() int

func (*OpEvaluator) XXX_Unmarshal 

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

type OpLuaDescriptor 

type OpLuaDescriptor struct {
	Code                 *wrappers.StringValue `protobuf:"bytes,8,opt,name=code,proto3" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpLuaDescriptor) Descriptor 

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

func (*OpLuaDescriptor) GetCode 

func (m *OpLuaDescriptor) GetCode() *wrappers.StringValue

func (*OpLuaDescriptor) ProtoMessage 

func (*OpLuaDescriptor) ProtoMessage()

func (*OpLuaDescriptor) Reset 

func (m *OpLuaDescriptor) Reset()

func (*OpLuaDescriptor) String 

func (m *OpLuaDescriptor) String() string

func (*OpLuaDescriptor) Validate 

func (this *OpLuaDescriptor) Validate() error

func (*OpLuaDescriptor) XXX_DiscardUnknown 

func (m *OpLuaDescriptor) XXX_DiscardUnknown()

func (*OpLuaDescriptor) XXX_Marshal 

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

func (*OpLuaDescriptor) XXX_Merge 

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

func (*OpLuaDescriptor) XXX_Size 

func (m *OpLuaDescriptor) XXX_Size() int

func (*OpLuaDescriptor) XXX_Unmarshal 

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

type OpOperator 

type OpOperator struct {
	Id          *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias       *wrappers.StringValue `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description *wrappers.StringValue `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Driver      *wrappers.StringValue `protobuf:"bytes,8,opt,name=driver,proto3" json:"driver,omitempty"`
	// Types that are valid to be assigned to Descriptor_:
	//	*OpOperator_Lua
	Descriptor_          isOpOperator_Descriptor_ `protobuf_oneof:"descriptor"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*OpOperator) Descriptor 

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

func (*OpOperator) GetAlias 

func (m *OpOperator) GetAlias() *wrappers.StringValue

func (*OpOperator) GetDescription 

func (m *OpOperator) GetDescription() *wrappers.StringValue

func (*OpOperator) GetDescriptor_ 

func (m *OpOperator) GetDescriptor_() isOpOperator_Descriptor_

func (*OpOperator) GetDriver 

func (m *OpOperator) GetDriver() *wrappers.StringValue

func (*OpOperator) GetId 

func (m *OpOperator) GetId() *wrappers.StringValue

func (*OpOperator) GetLua 

func (m *OpOperator) GetLua() *OpLuaDescriptor

func (*OpOperator) ProtoMessage 

func (*OpOperator) ProtoMessage()

func (*OpOperator) Reset 

func (m *OpOperator) Reset()

func (*OpOperator) String 

func (m *OpOperator) String() string

func (*OpOperator) Validate 

func (this *OpOperator) Validate() error

func (*OpOperator) XXX_DiscardUnknown 

func (m *OpOperator) XXX_DiscardUnknown()

func (*OpOperator) XXX_Marshal 

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

func (*OpOperator) XXX_Merge 

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

func (*OpOperator) XXX_OneofWrappers 

func (*OpOperator) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OpOperator) XXX_Size 

func (m *OpOperator) XXX_Size() int

func (*OpOperator) XXX_Unmarshal 

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

type OpOperator_Lua 

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

type OpResource 

type OpResource struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 *wrappers.StringValue `protobuf:"bytes,8,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpResource) Descriptor 

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

func (*OpResource) GetId 

func (m *OpResource) GetId() *wrappers.StringValue

func (*OpResource) GetType 

func (m *OpResource) GetType() *wrappers.StringValue

func (*OpResource) ProtoMessage 

func (*OpResource) ProtoMessage()

func (*OpResource) Reset 

func (m *OpResource) Reset()

func (*OpResource) String 

func (m *OpResource) String() string

func (*OpResource) Validate 

func (this *OpResource) Validate() error

func (*OpResource) XXX_DiscardUnknown 

func (m *OpResource) XXX_DiscardUnknown()

func (*OpResource) XXX_Marshal 

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

func (*OpResource) XXX_Merge 

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

func (*OpResource) XXX_Size 

func (m *OpResource) XXX_Size() int

func (*OpResource) XXX_Unmarshal 

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

type OpTask added in v1.1.28 

type OpTask struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt            *timestamp.Timestamp  `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpTask) Descriptor added in v1.1.28 

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

func (*OpTask) GetCreatedAt added in v1.1.28 

func (m *OpTask) GetCreatedAt() *timestamp.Timestamp

func (*OpTask) GetCurrentState added in v1.1.28 

func (m *OpTask) GetCurrentState() *OpTaskState

func (*OpTask) GetId added in v1.1.28 

func (m *OpTask) GetId() *wrappers.StringValue

func (*OpTask) GetSource added in v1.1.28 

func (m *OpTask) GetSource() *OpResource

func (*OpTask) GetUpdatedAt added in v1.1.28 

func (m *OpTask) GetUpdatedAt() *timestamp.Timestamp

func (*OpTask) ProtoMessage added in v1.1.28 

func (*OpTask) ProtoMessage()

func (*OpTask) Reset added in v1.1.28 

func (m *OpTask) Reset()

func (*OpTask) String added in v1.1.28 

func (m *OpTask) String() string

func (*OpTask) Validate added in v1.1.28 

func (this *OpTask) Validate() error

func (*OpTask) XXX_DiscardUnknown added in v1.1.28 

func (m *OpTask) XXX_DiscardUnknown()

func (*OpTask) XXX_Marshal added in v1.1.28 

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

func (*OpTask) XXX_Merge added in v1.1.28 

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

func (*OpTask) XXX_Size added in v1.1.28 

func (m *OpTask) XXX_Size() int

func (*OpTask) XXX_Unmarshal added in v1.1.28 

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

type OpTaskState added in v1.1.28 

type OpTaskState struct {
	At                   *timestamp.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                 *_struct.Struct      `protobuf:"bytes,8,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*OpTaskState) Descriptor added in v1.1.28 

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

func (*OpTaskState) GetAt added in v1.1.28 

func (m *OpTaskState) GetAt() *timestamp.Timestamp

func (*OpTaskState) GetState added in v1.1.28 

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

func (*OpTaskState) GetTags added in v1.1.28 

func (m *OpTaskState) GetTags() *_struct.Struct

func (*OpTaskState) ProtoMessage added in v1.1.28 

func (*OpTaskState) ProtoMessage()

func (*OpTaskState) Reset added in v1.1.28 

func (m *OpTaskState) Reset()

func (*OpTaskState) String added in v1.1.28 

func (m *OpTaskState) String() string

func (*OpTaskState) Validate added in v1.1.28 

func (this *OpTaskState) Validate() error

func (*OpTaskState) XXX_DiscardUnknown added in v1.1.28 

func (m *OpTaskState) XXX_DiscardUnknown()

func (*OpTaskState) XXX_Marshal added in v1.1.28 

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

func (*OpTaskState) XXX_Merge added in v1.1.28 

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

func (*OpTaskState) XXX_Size added in v1.1.28 

func (m *OpTaskState) XXX_Size() int

func (*OpTaskState) XXX_Unmarshal added in v1.1.28 

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

type OpTimer added in v1.1.28 

type OpTimer struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,24,opt,name=alias,proto3" json:"alias,omitempty"`
	Description          *wrappers.StringValue `protobuf:"bytes,25,opt,name=description,proto3" json:"description,omitempty"`
	Schedule             *wrappers.StringValue `protobuf:"bytes,8,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Timezone             *wrappers.StringValue `protobuf:"bytes,9,opt,name=timezone,proto3" json:"timezone,omitempty"`
	Enabled              *wrappers.BoolValue   `protobuf:"bytes,10,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Configs              []*deviced.OpConfig   `protobuf:"bytes,11,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpTimer) Descriptor added in v1.1.28 

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

func (*OpTimer) GetAlias added in v1.1.28 

func (m *OpTimer) GetAlias() *wrappers.StringValue

func (*OpTimer) GetConfigs added in v1.1.28 

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

func (*OpTimer) GetDescription added in v1.1.28 

func (m *OpTimer) GetDescription() *wrappers.StringValue

func (*OpTimer) GetEnabled added in v1.1.28 

func (m *OpTimer) GetEnabled() *wrappers.BoolValue

func (*OpTimer) GetId added in v1.1.28 

func (m *OpTimer) GetId() *wrappers.StringValue

func (*OpTimer) GetSchedule added in v1.1.28 

func (m *OpTimer) GetSchedule() *wrappers.StringValue

func (*OpTimer) GetTimezone added in v1.1.28 

func (m *OpTimer) GetTimezone() *wrappers.StringValue

func (*OpTimer) ProtoMessage added in v1.1.28 

func (*OpTimer) ProtoMessage()

func (*OpTimer) Reset added in v1.1.28 

func (m *OpTimer) Reset()

func (*OpTimer) String added in v1.1.28 

func (m *OpTimer) String() string

func (*OpTimer) Validate added in v1.1.28 

func (this *OpTimer) Validate() error

func (*OpTimer) XXX_DiscardUnknown added in v1.1.28 

func (m *OpTimer) XXX_DiscardUnknown()

func (*OpTimer) XXX_Marshal added in v1.1.28 

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

func (*OpTimer) XXX_Merge added in v1.1.28 

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

func (*OpTimer) XXX_Size added in v1.1.28 

func (m *OpTimer) XXX_Size() int

func (*OpTimer) XXX_Unmarshal added in v1.1.28 

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

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 valid to be assigned to Descriptor_:
	//	*Operator_Lua
	Descriptor_          isOperator_Descriptor_ `protobuf_oneof:"descriptor"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Operator) Descriptor 

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

func (*Operator) GetAlias 

func (m *Operator) GetAlias() string

func (*Operator) GetDescription 

func (m *Operator) GetDescription() string

func (*Operator) GetDescriptor_ 

func (m *Operator) GetDescriptor_() isOperator_Descriptor_

func (*Operator) GetDriver 

func (m *Operator) GetDriver() string

func (*Operator) GetId 

func (m *Operator) GetId() string

func (*Operator) GetLua 

func (m *Operator) GetLua() *LuaDescriptor

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) Reset 

func (m *Operator) Reset()

func (*Operator) String 

func (m *Operator) String() string

func (*Operator) Validate 

func (this *Operator) Validate() error

func (*Operator) XXX_DiscardUnknown 

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal 

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

func (*Operator) XXX_Merge 

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

func (*Operator) XXX_OneofWrappers 

func (*Operator) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Operator) XXX_Size 

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PatchEvaluatorRequest) Descriptor 

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

func (*PatchEvaluatorRequest) GetEvaluator 

func (m *PatchEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*PatchEvaluatorRequest) ProtoMessage 

func (*PatchEvaluatorRequest) ProtoMessage()

func (*PatchEvaluatorRequest) Reset 

func (m *PatchEvaluatorRequest) Reset()

func (*PatchEvaluatorRequest) String 

func (m *PatchEvaluatorRequest) String() string

func (*PatchEvaluatorRequest) Validate 

func (this *PatchEvaluatorRequest) Validate() error

func (*PatchEvaluatorRequest) XXX_DiscardUnknown 

func (m *PatchEvaluatorRequest) XXX_DiscardUnknown()

func (*PatchEvaluatorRequest) XXX_Marshal 

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

func (*PatchEvaluatorRequest) XXX_Merge 

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

func (*PatchEvaluatorRequest) XXX_Size 

func (m *PatchEvaluatorRequest) XXX_Size() int

func (*PatchEvaluatorRequest) XXX_Unmarshal 

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

type PatchEvaluatorResponse 

type PatchEvaluatorResponse struct {
	Evaluator            *Evaluator `protobuf:"bytes,1,opt,name=evaluator,proto3" json:"evaluator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PatchEvaluatorResponse) Descriptor 

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

func (*PatchEvaluatorResponse) GetEvaluator 

func (m *PatchEvaluatorResponse) GetEvaluator() *Evaluator

func (*PatchEvaluatorResponse) ProtoMessage 

func (*PatchEvaluatorResponse) ProtoMessage()

func (*PatchEvaluatorResponse) Reset 

func (m *PatchEvaluatorResponse) Reset()

func (*PatchEvaluatorResponse) String 

func (m *PatchEvaluatorResponse) String() string

func (*PatchEvaluatorResponse) Validate 

func (this *PatchEvaluatorResponse) Validate() error

func (*PatchEvaluatorResponse) XXX_DiscardUnknown 

func (m *PatchEvaluatorResponse) XXX_DiscardUnknown()

func (*PatchEvaluatorResponse) XXX_Marshal 

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

func (*PatchEvaluatorResponse) XXX_Merge 

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

func (*PatchEvaluatorResponse) XXX_Size 

func (m *PatchEvaluatorResponse) XXX_Size() int

func (*PatchEvaluatorResponse) XXX_Unmarshal 

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

type PatchTimerRequest added in v1.1.28 

type PatchTimerRequest struct {
	Timer                *OpTimer `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PatchTimerRequest) Descriptor added in v1.1.28 

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

func (*PatchTimerRequest) GetTimer added in v1.1.28 

func (m *PatchTimerRequest) GetTimer() *OpTimer

func (*PatchTimerRequest) ProtoMessage added in v1.1.28 

func (*PatchTimerRequest) ProtoMessage()

func (*PatchTimerRequest) Reset added in v1.1.28 

func (m *PatchTimerRequest) Reset()

func (*PatchTimerRequest) String added in v1.1.28 

func (m *PatchTimerRequest) String() string

func (*PatchTimerRequest) Validate added in v1.1.28 

func (this *PatchTimerRequest) Validate() error

func (*PatchTimerRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *PatchTimerRequest) XXX_DiscardUnknown()

func (*PatchTimerRequest) XXX_Marshal added in v1.1.28 

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

func (*PatchTimerRequest) XXX_Merge added in v1.1.28 

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

func (*PatchTimerRequest) XXX_Size added in v1.1.28 

func (m *PatchTimerRequest) XXX_Size() int

func (*PatchTimerRequest) XXX_Unmarshal added in v1.1.28 

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

type PatchTimerResponse added in v1.1.28 

type PatchTimerResponse struct {
	Timer                *Timer   `protobuf:"bytes,1,opt,name=timer,proto3" json:"timer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PatchTimerResponse) Descriptor added in v1.1.28 

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

func (*PatchTimerResponse) GetTimer added in v1.1.28 

func (m *PatchTimerResponse) GetTimer() *Timer

func (*PatchTimerResponse) ProtoMessage added in v1.1.28 

func (*PatchTimerResponse) ProtoMessage()

func (*PatchTimerResponse) Reset added in v1.1.28 

func (m *PatchTimerResponse) Reset()

func (*PatchTimerResponse) String added in v1.1.28 

func (m *PatchTimerResponse) String() string

func (*PatchTimerResponse) Validate added in v1.1.28 

func (this *PatchTimerResponse) Validate() error

func (*PatchTimerResponse) XXX_DiscardUnknown added in v1.1.28 

func (m *PatchTimerResponse) XXX_DiscardUnknown()

func (*PatchTimerResponse) XXX_Marshal added in v1.1.28 

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

func (*PatchTimerResponse) XXX_Merge added in v1.1.28 

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

func (*PatchTimerResponse) XXX_Size added in v1.1.28 

func (m *PatchTimerResponse) XXX_Size() int

func (*PatchTimerResponse) XXX_Unmarshal added in v1.1.28 

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

type QueryStorageByDeviceRequest added in v1.2.5 

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          *wrappers.StringValue          `protobuf:"bytes,3,opt,name=measurement,proto3" json:"measurement,omitempty"`
	RangeFrom            *timestamp.Timestamp           `protobuf:"bytes,4,opt,name=range_from,json=rangeFrom,proto3" json:"range_from,omitempty"`
	RangeTo              *timestamp.Timestamp           `protobuf:"bytes,5,opt,name=range_to,json=rangeTo,proto3" json:"range_to,omitempty"`
	QueryString          *wrappers.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"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*QueryStorageByDeviceRequest) Descriptor added in v1.2.5 

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

func (*QueryStorageByDeviceRequest) GetDevice added in v1.2.5 

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

func (*QueryStorageByDeviceRequest) GetMeasurement added in v1.2.5 

func (m *QueryStorageByDeviceRequest) GetMeasurement() *wrappers.StringValue

func (*QueryStorageByDeviceRequest) GetPagination added in v1.2.5 

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

func (*QueryStorageByDeviceRequest) GetQueryString added in v1.2.5 

func (m *QueryStorageByDeviceRequest) GetQueryString() *wrappers.StringValue

func (*QueryStorageByDeviceRequest) GetRangeFrom added in v1.2.5 

func (m *QueryStorageByDeviceRequest) GetRangeFrom() *timestamp.Timestamp

func (*QueryStorageByDeviceRequest) GetRangeTo added in v1.2.5 

func (m *QueryStorageByDeviceRequest) GetRangeTo() *timestamp.Timestamp

func (*QueryStorageByDeviceRequest) GetSource added in v1.2.5 

func (m *QueryStorageByDeviceRequest) GetSource() *OpResource

func (*QueryStorageByDeviceRequest) ProtoMessage added in v1.2.5 

func (*QueryStorageByDeviceRequest) ProtoMessage()

func (*QueryStorageByDeviceRequest) Reset added in v1.2.5 

func (m *QueryStorageByDeviceRequest) Reset()

func (*QueryStorageByDeviceRequest) String added in v1.2.5 

func (m *QueryStorageByDeviceRequest) String() string

func (*QueryStorageByDeviceRequest) Validate added in v1.2.5 

func (this *QueryStorageByDeviceRequest) Validate() error

func (*QueryStorageByDeviceRequest) XXX_DiscardUnknown added in v1.2.5 

func (m *QueryStorageByDeviceRequest) XXX_DiscardUnknown()

func (*QueryStorageByDeviceRequest) XXX_Marshal added in v1.2.5 

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

func (*QueryStorageByDeviceRequest) XXX_Merge added in v1.2.5 

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

func (*QueryStorageByDeviceRequest) XXX_Size added in v1.2.5 

func (m *QueryStorageByDeviceRequest) XXX_Size() int

func (*QueryStorageByDeviceRequest) XXX_Unmarshal added in v1.2.5 

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

type QueryStorageByDeviceResponse added in v1.2.5 

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"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*QueryStorageByDeviceResponse) Descriptor added in v1.2.5 

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

func (*QueryStorageByDeviceResponse) GetFrames added in v1.2.5 

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

func (*QueryStorageByDeviceResponse) GetPagination added in v1.2.5 

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

func (*QueryStorageByDeviceResponse) ProtoMessage added in v1.2.5 

func (*QueryStorageByDeviceResponse) ProtoMessage()

func (*QueryStorageByDeviceResponse) Reset added in v1.2.5 

func (m *QueryStorageByDeviceResponse) Reset()

func (*QueryStorageByDeviceResponse) String added in v1.2.5 

func (m *QueryStorageByDeviceResponse) String() string

func (*QueryStorageByDeviceResponse) Validate added in v1.2.5 

func (this *QueryStorageByDeviceResponse) Validate() error

func (*QueryStorageByDeviceResponse) XXX_DiscardUnknown added in v1.2.5 

func (m *QueryStorageByDeviceResponse) XXX_DiscardUnknown()

func (*QueryStorageByDeviceResponse) XXX_Marshal added in v1.2.5 

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

func (*QueryStorageByDeviceResponse) XXX_Merge added in v1.2.5 

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

func (*QueryStorageByDeviceResponse) XXX_Size added in v1.2.5 

func (m *QueryStorageByDeviceResponse) XXX_Size() int

func (*QueryStorageByDeviceResponse) XXX_Unmarshal added in v1.2.5 

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

type RemoveConfigsFromTimerRequest added in v1.1.28 

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RemoveConfigsFromTimerRequest) Descriptor added in v1.1.28 

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

func (*RemoveConfigsFromTimerRequest) GetConfigs added in v1.1.28 

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

func (*RemoveConfigsFromTimerRequest) GetTimer added in v1.1.28 

func (m *RemoveConfigsFromTimerRequest) GetTimer() *OpTimer

func (*RemoveConfigsFromTimerRequest) ProtoMessage added in v1.1.28 

func (*RemoveConfigsFromTimerRequest) ProtoMessage()

func (*RemoveConfigsFromTimerRequest) Reset added in v1.1.28 

func (m *RemoveConfigsFromTimerRequest) Reset()

func (*RemoveConfigsFromTimerRequest) String added in v1.1.28 

func (m *RemoveConfigsFromTimerRequest) String() string

func (*RemoveConfigsFromTimerRequest) Validate added in v1.1.28 

func (this *RemoveConfigsFromTimerRequest) Validate() error

func (*RemoveConfigsFromTimerRequest) XXX_DiscardUnknown added in v1.1.28 

func (m *RemoveConfigsFromTimerRequest) XXX_DiscardUnknown()

func (*RemoveConfigsFromTimerRequest) XXX_Marshal added in v1.1.28 

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

func (*RemoveConfigsFromTimerRequest) XXX_Merge added in v1.1.28 

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

func (*RemoveConfigsFromTimerRequest) XXX_Size added in v1.1.28 

func (m *RemoveConfigsFromTimerRequest) XXX_Size() int

func (*RemoveConfigsFromTimerRequest) XXX_Unmarshal added in v1.1.28 

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

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RemoveSourcesFromEvaluatorRequest) Descriptor 

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

func (*RemoveSourcesFromEvaluatorRequest) GetEvaluator 

func (m *RemoveSourcesFromEvaluatorRequest) GetEvaluator() *OpEvaluator

func (*RemoveSourcesFromEvaluatorRequest) GetSources 

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

func (*RemoveSourcesFromEvaluatorRequest) ProtoMessage 

func (*RemoveSourcesFromEvaluatorRequest) ProtoMessage()

func (*RemoveSourcesFromEvaluatorRequest) Reset 

func (m *RemoveSourcesFromEvaluatorRequest) Reset()

func (*RemoveSourcesFromEvaluatorRequest) String 

func (m *RemoveSourcesFromEvaluatorRequest) String() string

func (*RemoveSourcesFromEvaluatorRequest) Validate 

func (this *RemoveSourcesFromEvaluatorRequest) Validate() error

func (*RemoveSourcesFromEvaluatorRequest) XXX_DiscardUnknown 

func (m *RemoveSourcesFromEvaluatorRequest) XXX_DiscardUnknown()

func (*RemoveSourcesFromEvaluatorRequest) XXX_Marshal 

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

func (*RemoveSourcesFromEvaluatorRequest) XXX_Merge 

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

func (*RemoveSourcesFromEvaluatorRequest) XXX_Size 

func (m *RemoveSourcesFromEvaluatorRequest) XXX_Size() int

func (*RemoveSourcesFromEvaluatorRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Resource) Descriptor 

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

func (*Resource) GetId 

func (m *Resource) GetId() string

func (*Resource) GetType 

func (m *Resource) GetType() string

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) String 

func (m *Resource) String() string

func (*Resource) Validate 

func (this *Resource) Validate() error

func (*Resource) XXX_DiscardUnknown 

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal 

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

func (*Resource) XXX_Merge 

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

func (*Resource) XXX_Size 

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal 

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

type Task added in v1.1.28 

type Task struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Task) Descriptor added in v1.1.28 

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

func (*Task) GetCreatedAt added in v1.1.28 

func (m *Task) GetCreatedAt() *timestamp.Timestamp

func (*Task) GetCurrentState added in v1.1.28 

func (m *Task) GetCurrentState() *TaskState

func (*Task) GetId added in v1.1.28 

func (m *Task) GetId() string

func (*Task) GetSource added in v1.1.28 

func (m *Task) GetSource() *Resource

func (*Task) GetStates added in v1.1.28 

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

func (*Task) GetUpdatedAt added in v1.1.28 

func (m *Task) GetUpdatedAt() *timestamp.Timestamp

func (*Task) ProtoMessage added in v1.1.28 

func (*Task) ProtoMessage()

func (*Task) Reset added in v1.1.28 

func (m *Task) Reset()

func (*Task) String added in v1.1.28 

func (m *Task) String() string

func (*Task) Validate added in v1.1.28 

func (this *Task) Validate() error

func (*Task) XXX_DiscardUnknown added in v1.1.28 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal added in v1.1.28 

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

func (*Task) XXX_Merge added in v1.1.28 

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

func (*Task) XXX_Size added in v1.1.28 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal added in v1.1.28 

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

type TaskState added in v1.1.28 

type TaskState struct {
	At                   *timestamp.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                 *_struct.Struct      `protobuf:"bytes,8,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TaskState) Descriptor added in v1.1.28 

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

func (*TaskState) GetAt added in v1.1.28 

func (m *TaskState) GetAt() *timestamp.Timestamp

func (*TaskState) GetState added in v1.1.28 

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

func (*TaskState) GetTags added in v1.1.28 

func (m *TaskState) GetTags() *_struct.Struct

func (*TaskState) ProtoMessage added in v1.1.28 

func (*TaskState) ProtoMessage()

func (*TaskState) Reset added in v1.1.28 

func (m *TaskState) Reset()

func (*TaskState) String added in v1.1.28 

func (m *TaskState) String() string

func (*TaskState) Validate added in v1.1.28 

func (this *TaskState) Validate() error

func (*TaskState) XXX_DiscardUnknown added in v1.1.28 

func (m *TaskState) XXX_DiscardUnknown()

func (*TaskState) XXX_Marshal added in v1.1.28 

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

func (*TaskState) XXX_Merge added in v1.1.28 

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

func (*TaskState) XXX_Size added in v1.1.28 

func (m *TaskState) XXX_Size() int

func (*TaskState) XXX_Unmarshal added in v1.1.28 

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

type Timer added in v1.1.28 

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Timer) Descriptor added in v1.1.28 

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

func (*Timer) GetAlias added in v1.1.28 

func (m *Timer) GetAlias() string

func (*Timer) GetConfigs added in v1.1.28 

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

func (*Timer) GetDescription added in v1.1.28 

func (m *Timer) GetDescription() string

func (*Timer) GetEnabled added in v1.1.28 

func (m *Timer) GetEnabled() bool

func (*Timer) GetId added in v1.1.28 

func (m *Timer) GetId() string

func (*Timer) GetSchedule added in v1.1.28 

func (m *Timer) GetSchedule() string

func (*Timer) GetTimezone added in v1.1.28 

func (m *Timer) GetTimezone() string

func (*Timer) ProtoMessage added in v1.1.28 

func (*Timer) ProtoMessage()

func (*Timer) Reset added in v1.1.28 

func (m *Timer) Reset()

func (*Timer) String added in v1.1.28 

func (m *Timer) String() string

func (*Timer) Validate added in v1.1.28 

func (this *Timer) Validate() error

func (*Timer) XXX_DiscardUnknown added in v1.1.28 

func (m *Timer) XXX_DiscardUnknown()

func (*Timer) XXX_Marshal added in v1.1.28 

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

func (*Timer) XXX_Merge added in v1.1.28 

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

func (*Timer) XXX_Size added in v1.1.28 

func (m *Timer) XXX_Size() int

func (*Timer) XXX_Unmarshal added in v1.1.28 

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

type UnimplementedEvaluatordServiceServer 

type UnimplementedEvaluatordServiceServer struct {
}

UnimplementedEvaluatordServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEvaluatordServiceServer) AddConfigsToTimer added in v1.1.28 

func (*UnimplementedEvaluatordServiceServer) AddConfigsToTimer(ctx context.Context, req *AddConfigsToTimerRequest) (*empty.Empty, error)

func (*UnimplementedEvaluatordServiceServer) AddSourcesToEvaluator 

func (*UnimplementedEvaluatordServiceServer) AddSourcesToEvaluator(ctx context.Context, req *AddSourcesToEvaluatorRequest) (*empty.Empty, error)

func (*UnimplementedEvaluatordServiceServer) CreateEvaluator 

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

func (*UnimplementedEvaluatordServiceServer) CreateTimer added in v1.1.28 

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

func (*UnimplementedEvaluatordServiceServer) DeleteEvaluator 

func (*UnimplementedEvaluatordServiceServer) DeleteEvaluator(ctx context.Context, req *DeleteEvaluatorRequest) (*empty.Empty, error)

func (*UnimplementedEvaluatordServiceServer) DeleteTimer added in v1.1.28 

func (*UnimplementedEvaluatordServiceServer) DeleteTimer(ctx context.Context, req *DeleteTimerRequest) (*empty.Empty, error)

func (*UnimplementedEvaluatordServiceServer) GetEvaluator 

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

func (*UnimplementedEvaluatordServiceServer) GetTask added in v1.1.28 

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

func (*UnimplementedEvaluatordServiceServer) GetTimer added in v1.1.28 

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

func (*UnimplementedEvaluatordServiceServer) ListEvaluators 

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

func (*UnimplementedEvaluatordServiceServer) ListEvaluatorsBySource 

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

func (*UnimplementedEvaluatordServiceServer) ListTasksBySource added in v1.1.28 

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

func (*UnimplementedEvaluatordServiceServer) ListTimers added in v1.1.28 

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

func (*UnimplementedEvaluatordServiceServer) PatchEvaluator 

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

func (*UnimplementedEvaluatordServiceServer) PatchTimer added in v1.1.28 

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

func (*UnimplementedEvaluatordServiceServer) QueryStorageByDevice added in v1.2.5 

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

func (*UnimplementedEvaluatordServiceServer) RemoveConfigsFromTimer added in v1.1.28 

func (*UnimplementedEvaluatordServiceServer) RemoveConfigsFromTimer(ctx context.Context, req *RemoveConfigsFromTimerRequest) (*empty.Empty, error)

func (*UnimplementedEvaluatordServiceServer) RemoveSourcesFromEvaluator 

func (*UnimplementedEvaluatordServiceServer) RemoveSourcesFromEvaluator(ctx context.Context, req *RemoveSourcesFromEvaluatorRequest) (*empty.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.