metathings_plugin_evaluator_cmd

Documentation

Index

• func GetEvaluatorPluginOptions(opt *EvaluatorPluginOption) (cmd_contrib.LoggerOptioner, cmd_contrib.ServiceOptioner, ...)
• func LoadEvaluatorPluginOption(path string) func() (*EvaluatorPluginOption, error)
• func NewCaller(o *EvaluatorPluginOption, cli_fty *client_helper.ClientFactory, ...) (dsdk.Caller, error)
• func NewDataStorage(o *EvaluatorPluginOption, logger log.FieldLogger) (dssdk.DataStorage, error)
• func NewEvaluatorPluginService(cfg string) (*service.EvaluatorPluginService, error)
• func NewEvaluatorPluginServiceOption(p NewEvaluatorPluginOptionParams) (*service.EvaluatorPluginServiceOption, error)
• func NewFlow(o *EvaluatorPluginOption, cli_fty *client_helper.ClientFactory, ...) (dsdk.Flow, error)
• func NewSimpleStorage(o *EvaluatorPluginOption, cli_fty *client_helper.ClientFactory, ...) (dsdk.SimpleStorage, error)
• func NewTaskStorage(p NewTaskStorageParams) (evaluatord_storage.TaskStorage, error)
• type EvaluatorPluginOption
  • func NewEvaluatorPluginOption() *EvaluatorPluginOption
• type NewEvaluatorPluginOptionParams
• type NewTaskStorageParams

Functions

func GetEvaluatorPluginOptions

func GetEvaluatorPluginOptions(opt *EvaluatorPluginOption) (
	cmd_contrib.LoggerOptioner,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.CredentialOptioner,
	cmd_contrib.ServiceEndpointsOptioner,
	cmd_contrib.OpentracingOptioner,
)

func LoadEvaluatorPluginOption

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

func NewCaller

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

func NewDataStorage

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

func NewEvaluatorPluginService

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

func NewEvaluatorPluginServiceOption

func NewEvaluatorPluginServiceOption(p NewEvaluatorPluginOptionParams) (*service.EvaluatorPluginServiceOption, error)

func NewFlow

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

func NewSimpleStorage

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

func NewTaskStorage

func NewTaskStorage(p NewTaskStorageParams) (evaluatord_storage.TaskStorage, error)

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

type NewEvaluatorPluginOptionParams struct {
	fx.In

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

type NewTaskStorageParams

type NewTaskStorageParams struct {
	fx.In

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