metathings_plugin_evaluator_cmd

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: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadEvaluatorPluginOption

func LoadEvaluatorPluginOption(path string) func() (*EvaluatorPluginOption, error)

func NewCaller added in v1.1.27

func NewDataStorage added in v1.1.26

func NewDataStorage(o *EvaluatorPluginOption, logger log.FieldLogger) (dssdk.DataStorage, error)

func NewEvaluatorPluginService

func NewEvaluatorPluginService(cfg string) (*service.EvaluatorPluginService, error)

func NewFlow added in v1.2.3

func NewSimpleStorage added in v1.1.26

func NewSimpleStorage(o *EvaluatorPluginOption, cli_fty *client_helper.ClientFactory, logger log.FieldLogger) (dsdk.SimpleStorage, error)

func NewTaskStorage added in v1.1.28

Types

type EvaluatorPluginOption

type EvaluatorPluginOption struct {
	cmd_contrib.ServiceBaseOption `mapstructure:",squash"`
	Evaluator                     struct {
		Endpoint string
	}
	Server struct {
		Name string
	}
	DataStorage   map[string]interface{}
	SimpleStorage map[string]interface{}
	Flow          map[string]interface{}
	TaskStorage   map[string]interface{}
	Callback      map[string]interface{}
	Caller        map[string]interface{}
	SmsSender     map[string]interface{}
}

func NewEvaluatorPluginOption

func NewEvaluatorPluginOption() *EvaluatorPluginOption

type NewEvaluatorPluginOptionParams added in v1.1.28

type NewEvaluatorPluginOptionParams struct {
	fx.In

	Tracer opentracing.Tracer `name:"opentracing_tracer"`
	Option *EvaluatorPluginOption
}

type NewTaskStorageParams added in v1.1.28

type NewTaskStorageParams struct {
	fx.In

	Option *EvaluatorPluginOption
	Logger log.FieldLogger
	Tracer opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL