metathings_plugin_evaluator_service

Documentation

Index

• Constants
• Variables
• type EvaluatorPluginService
  • func NewEvaluatorPluginService(opt *EvaluatorPluginServiceOption, logger log.FieldLogger, ...) (*EvaluatorPluginService, error)
  • func (srv *EvaluatorPluginService) Eval(w http.ResponseWriter, r *http.Request)
  • func (srv *EvaluatorPluginService) HandleResponse(w http.ResponseWriter, r *http.Request, hs *hst.HttpStatus)
  • func (srv *EvaluatorPluginService) IsTraced(*http.Request) bool
  • func (srv *EvaluatorPluginService) ReceiveData(w http.ResponseWriter, r *http.Request)
  • func (srv *EvaluatorPluginService) TimerWebhook(w http.ResponseWriter, r *http.Request)
• type EvaluatorPluginServiceOption
  • func NewEvaluatorPluginServiceOption() *EvaluatorPluginServiceOption
• type GetParamFunc

Constants

const (
	TIMER_DATA_CODEC = "json"
)

Variables

var (
	ErrTimerDefaultConfigNotFound = errors.New("timer default config not found")
)

Types

type EvaluatorPluginService

type EvaluatorPluginService struct {
	// contains filtered or unexported fields
}

func NewEvaluatorPluginService

func NewEvaluatorPluginService(
	opt *EvaluatorPluginServiceOption,
	logger log.FieldLogger,
	tknr token_helper.Tokener,
	dat_stor dssdk.DataStorage,
	smpl_stor dsdk.SimpleStorage,
	flow dsdk.Flow,
	task_stor evltr_stor.TaskStorage,
	caller dsdk.Caller,
	cli_fty *client_helper.ClientFactory,
) (*EvaluatorPluginService, error)

func (*EvaluatorPluginService) Eval

func (srv *EvaluatorPluginService) Eval(w http.ResponseWriter, r *http.Request)

func (*EvaluatorPluginService) HandleResponse

func (srv *EvaluatorPluginService) HandleResponse(w http.ResponseWriter, r *http.Request, hs *hst.HttpStatus)

func (*EvaluatorPluginService) IsTraced

func (srv *EvaluatorPluginService) IsTraced(*http.Request) bool

func (*EvaluatorPluginService) ReceiveData

func (srv *EvaluatorPluginService) ReceiveData(w http.ResponseWriter, r *http.Request)

func (*EvaluatorPluginService) TimerWebhook

func (srv *EvaluatorPluginService) TimerWebhook(w http.ResponseWriter, r *http.Request)

type EvaluatorPluginServiceOption

type EvaluatorPluginServiceOption struct {
	Evaluator struct {
		Endpoint string
	}
	Server struct {
		Name string
	}
	Codec    string
	IsTraced bool

	Callback map[string]interface{}
}

func NewEvaluatorPluginServiceOption

func NewEvaluatorPluginServiceOption() *EvaluatorPluginServiceOption

type GetParamFunc

type GetParamFunc func(*http.Request, string) string