Documentation ¶
Index ¶
- func NewMetathingsEvaludatorService(opt *MetathingsEvaluatordServiceOption, logger log.FieldLogger, ...) (pb.EvaluatordServiceServer, error)
- type MetathingsEvaluatordService
- func (srv *MetathingsEvaluatordService) AddConfigsToTimer(ctx context.Context, req *pb.AddConfigsToTimerRequest) (*empty.Empty, error)
- func (srv *MetathingsEvaluatordService) AddSourcesToEvaluator(ctx context.Context, req *pb.AddSourcesToEvaluatorRequest) (_ *empty.Empty, err error)
- func (srv *MetathingsEvaluatordService) AuthorizeAddConfigsToTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeAddSourcesToEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeDeleteEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeDeleteTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeGetEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeGetTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeListEvaluatorsBySource(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeListTasksBySource(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizePatchEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizePatchTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeQueryStorageByDevice(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeRemoveConfigsFromTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) AuthorizeRemoveSourcesFromEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) CreateEvaluator(ctx context.Context, req *pb.CreateEvaluatorRequest) (res *pb.CreateEvaluatorResponse, err error)
- func (srv *MetathingsEvaluatordService) CreateTimer(ctx context.Context, req *pb.CreateTimerRequest) (*pb.CreateTimerResponse, error)
- func (srv *MetathingsEvaluatordService) DeleteEvaluator(ctx context.Context, req *pb.DeleteEvaluatorRequest) (_ *empty.Empty, err error)
- func (srv *MetathingsEvaluatordService) DeleteTimer(ctx context.Context, req *pb.DeleteTimerRequest) (_ *empty.Empty, err error)
- func (srv *MetathingsEvaluatordService) GetEvaluator(ctx context.Context, req *pb.GetEvaluatorRequest) (res *pb.GetEvaluatorResponse, err error)
- func (srv *MetathingsEvaluatordService) GetTask(ctx context.Context, req *pb.GetTaskRequest) (*pb.GetTaskResponse, error)
- func (srv *MetathingsEvaluatordService) GetTimer(ctx context.Context, req *pb.GetTimerRequest) (res *pb.GetTimerResponse, err error)
- func (srv *MetathingsEvaluatordService) IsIgnoreMethod(md *grpc_helper.MethodDescription) bool
- func (srv *MetathingsEvaluatordService) ListEvaluators(ctx context.Context, req *pb.ListEvaluatorsRequest) (res *pb.ListEvaluatorsResponse, err error)
- func (srv *MetathingsEvaluatordService) ListEvaluatorsBySource(ctx context.Context, req *pb.ListEvaluatorsBySourceRequest) (res *pb.ListEvaluatorsBySourceResponse, err error)
- func (srv *MetathingsEvaluatordService) ListTasksBySource(ctx context.Context, req *pb.ListTasksBySourceRequest) (*pb.ListTasksBySourceResponse, error)
- func (srv *MetathingsEvaluatordService) ListTimers(ctx context.Context, req *pb.ListTimersRequest) (*pb.ListTimersResponse, error)
- func (srv *MetathingsEvaluatordService) PatchEvaluator(ctx context.Context, req *pb.PatchEvaluatorRequest) (res *pb.PatchEvaluatorResponse, err error)
- func (srv *MetathingsEvaluatordService) PatchTimer(ctx context.Context, req *pb.PatchTimerRequest) (*pb.PatchTimerResponse, error)
- func (srv *MetathingsEvaluatordService) QueryStorageByDevice(ctx context.Context, req *pb.QueryStorageByDeviceRequest) (*pb.QueryStorageByDeviceResponse, error)
- func (srv *MetathingsEvaluatordService) RemoveConfigsFromTimer(ctx context.Context, req *pb.RemoveConfigsFromTimerRequest) (*empty.Empty, error)
- func (srv *MetathingsEvaluatordService) RemoveSourcesFromEvaluator(ctx context.Context, req *pb.RemoveSourcesFromEvaluatorRequest) (_ *empty.Empty, err error)
- func (srv *MetathingsEvaluatordService) ValidateAddConfigsToTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateAddSourcesToEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateCreateEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateCreateTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateDeleteEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateDeleteTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateGetEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateGetTask(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateGetTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateListEvaluatorsBySource(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateListTasksBySource(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidatePatchEvaluator(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidatePatchTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateQueryStorageByDevice(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateRemoveConfigsFromTimer(ctx context.Context, in interface{}) error
- func (srv *MetathingsEvaluatordService) ValidateRemoveSourcesFromEvaluator(ctx context.Context, in interface{}) error
- type MetathingsEvaluatordServiceOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMetathingsEvaludatorService ¶
func NewMetathingsEvaludatorService( opt *MetathingsEvaluatordServiceOption, logger log.FieldLogger, storage storage.Storage, task_storage storage.TaskStorage, data_storage dssdk.DataStorage, timer_storage storage.TimerStorage, timer_backend timer_backend.TimerBackend, authorizer identityd_authorizer.Authorizer, validator identityd_validator.Validator, tkvdr token_helper.TokenValidator, tknr token_helper.Tokener, cli_fty *client_helper.ClientFactory, ) (pb.EvaluatordServiceServer, error)
Types ¶
type MetathingsEvaluatordService ¶
type MetathingsEvaluatordService struct { pb.UnimplementedEvaluatordServiceServer grpc_auth.ServiceAuthFuncOverride *grpc_helper.ErrorParser // contains filtered or unexported fields }
func (*MetathingsEvaluatordService) AddConfigsToTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) AddConfigsToTimer(ctx context.Context, req *pb.AddConfigsToTimerRequest) (*empty.Empty, error)
func (*MetathingsEvaluatordService) AddSourcesToEvaluator ¶
func (srv *MetathingsEvaluatordService) AddSourcesToEvaluator(ctx context.Context, req *pb.AddSourcesToEvaluatorRequest) (_ *empty.Empty, err error)
func (*MetathingsEvaluatordService) AuthorizeAddConfigsToTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) AuthorizeAddConfigsToTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeAddSourcesToEvaluator ¶
func (srv *MetathingsEvaluatordService) AuthorizeAddSourcesToEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeDeleteEvaluator ¶
func (srv *MetathingsEvaluatordService) AuthorizeDeleteEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeDeleteTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) AuthorizeDeleteTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeGetEvaluator ¶
func (srv *MetathingsEvaluatordService) AuthorizeGetEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeGetTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) AuthorizeGetTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeListEvaluatorsBySource ¶
func (srv *MetathingsEvaluatordService) AuthorizeListEvaluatorsBySource(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeListTasksBySource ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) AuthorizeListTasksBySource(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizePatchEvaluator ¶
func (srv *MetathingsEvaluatordService) AuthorizePatchEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizePatchTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) AuthorizePatchTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeQueryStorageByDevice ¶ added in v1.2.5
func (srv *MetathingsEvaluatordService) AuthorizeQueryStorageByDevice(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeRemoveConfigsFromTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) AuthorizeRemoveConfigsFromTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) AuthorizeRemoveSourcesFromEvaluator ¶
func (srv *MetathingsEvaluatordService) AuthorizeRemoveSourcesFromEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) CreateEvaluator ¶
func (srv *MetathingsEvaluatordService) CreateEvaluator(ctx context.Context, req *pb.CreateEvaluatorRequest) (res *pb.CreateEvaluatorResponse, err error)
func (*MetathingsEvaluatordService) CreateTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) CreateTimer(ctx context.Context, req *pb.CreateTimerRequest) (*pb.CreateTimerResponse, error)
func (*MetathingsEvaluatordService) DeleteEvaluator ¶
func (srv *MetathingsEvaluatordService) DeleteEvaluator(ctx context.Context, req *pb.DeleteEvaluatorRequest) (_ *empty.Empty, err error)
func (*MetathingsEvaluatordService) DeleteTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) DeleteTimer(ctx context.Context, req *pb.DeleteTimerRequest) (_ *empty.Empty, err error)
func (*MetathingsEvaluatordService) GetEvaluator ¶
func (srv *MetathingsEvaluatordService) GetEvaluator(ctx context.Context, req *pb.GetEvaluatorRequest) (res *pb.GetEvaluatorResponse, err error)
func (*MetathingsEvaluatordService) GetTask ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) GetTask(ctx context.Context, req *pb.GetTaskRequest) (*pb.GetTaskResponse, error)
func (*MetathingsEvaluatordService) GetTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) GetTimer(ctx context.Context, req *pb.GetTimerRequest) (res *pb.GetTimerResponse, err error)
func (*MetathingsEvaluatordService) IsIgnoreMethod ¶
func (srv *MetathingsEvaluatordService) IsIgnoreMethod(md *grpc_helper.MethodDescription) bool
func (*MetathingsEvaluatordService) ListEvaluators ¶
func (srv *MetathingsEvaluatordService) ListEvaluators(ctx context.Context, req *pb.ListEvaluatorsRequest) (res *pb.ListEvaluatorsResponse, err error)
func (*MetathingsEvaluatordService) ListEvaluatorsBySource ¶
func (srv *MetathingsEvaluatordService) ListEvaluatorsBySource(ctx context.Context, req *pb.ListEvaluatorsBySourceRequest) (res *pb.ListEvaluatorsBySourceResponse, err error)
func (*MetathingsEvaluatordService) ListTasksBySource ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ListTasksBySource(ctx context.Context, req *pb.ListTasksBySourceRequest) (*pb.ListTasksBySourceResponse, error)
func (*MetathingsEvaluatordService) ListTimers ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ListTimers(ctx context.Context, req *pb.ListTimersRequest) (*pb.ListTimersResponse, error)
func (*MetathingsEvaluatordService) PatchEvaluator ¶
func (srv *MetathingsEvaluatordService) PatchEvaluator(ctx context.Context, req *pb.PatchEvaluatorRequest) (res *pb.PatchEvaluatorResponse, err error)
func (*MetathingsEvaluatordService) PatchTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) PatchTimer(ctx context.Context, req *pb.PatchTimerRequest) (*pb.PatchTimerResponse, error)
func (*MetathingsEvaluatordService) QueryStorageByDevice ¶ added in v1.2.5
func (srv *MetathingsEvaluatordService) QueryStorageByDevice(ctx context.Context, req *pb.QueryStorageByDeviceRequest) (*pb.QueryStorageByDeviceResponse, error)
func (*MetathingsEvaluatordService) RemoveConfigsFromTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) RemoveConfigsFromTimer(ctx context.Context, req *pb.RemoveConfigsFromTimerRequest) (*empty.Empty, error)
func (*MetathingsEvaluatordService) RemoveSourcesFromEvaluator ¶
func (srv *MetathingsEvaluatordService) RemoveSourcesFromEvaluator(ctx context.Context, req *pb.RemoveSourcesFromEvaluatorRequest) (_ *empty.Empty, err error)
func (*MetathingsEvaluatordService) ValidateAddConfigsToTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidateAddConfigsToTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateAddSourcesToEvaluator ¶
func (srv *MetathingsEvaluatordService) ValidateAddSourcesToEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateCreateEvaluator ¶
func (srv *MetathingsEvaluatordService) ValidateCreateEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateCreateTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidateCreateTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateDeleteEvaluator ¶
func (srv *MetathingsEvaluatordService) ValidateDeleteEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateDeleteTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidateDeleteTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateGetEvaluator ¶
func (srv *MetathingsEvaluatordService) ValidateGetEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateGetTask ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidateGetTask(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateGetTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidateGetTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateListEvaluatorsBySource ¶
func (srv *MetathingsEvaluatordService) ValidateListEvaluatorsBySource(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateListTasksBySource ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidateListTasksBySource(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidatePatchEvaluator ¶
func (srv *MetathingsEvaluatordService) ValidatePatchEvaluator(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidatePatchTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidatePatchTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateQueryStorageByDevice ¶ added in v1.2.5
func (srv *MetathingsEvaluatordService) ValidateQueryStorageByDevice(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateRemoveConfigsFromTimer ¶ added in v1.1.28
func (srv *MetathingsEvaluatordService) ValidateRemoveConfigsFromTimer(ctx context.Context, in interface{}) error
func (*MetathingsEvaluatordService) ValidateRemoveSourcesFromEvaluator ¶
func (srv *MetathingsEvaluatordService) ValidateRemoveSourcesFromEvaluator(ctx context.Context, in interface{}) error
Source Files ¶
- add_configs_to_timer.go
- add_sources_to_evaluator.go
- create_evaluator.go
- create_timer.go
- delete_evaluator.go
- delete_timer.go
- errors.go
- get_evaluator.go
- get_task.go
- get_timer.go
- helper.go
- list_evaluators.go
- list_evaluators_by_source.go
- list_tasks_by_source.go
- list_timers.go
- patch_evaluator.go
- patch_timer.go
- query_storage_by_device.go
- remove_configs_from_timer.go
- remove_sources_from_evaluator.go
- service.go
Click to show internal directories.
Click to hide internal directories.