metathings_evaluatord_service

package
v1.2.15 Latest Latest
Warning

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

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

Documentation

Index

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 {
	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

type MetathingsEvaluatordServiceOption 

type MetathingsEvaluatordServiceOption struct {
	Methods struct {
		QueryStorageByDevice struct {
			DefaultRangeFromDuration time.Duration
			DefaultPageSize          int32
		}
	}
}

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.