metathings_evaluatord_sdk

Documentation

Index

• Constants
• Variables
• func ExtractDevice(ctx context.Context) string
• func ExtractTags(ctx context.Context) map[string]string
• func ExtractTimestamp(ctx context.Context) time.Time
• func ExtractToken(ctx context.Context) string
• func ToData(d *Data) func(string, interface{}) error
• func WithDevice(ctx context.Context, dev string) context.Context
• func WithTags(ctx context.Context, tags map[string]string) context.Context
• func WithTimestamp(ctx context.Context, ts time.Time) context.Context
• func WithToken(ctx context.Context, tkn string) context.Context
• type Data
  • func DataFromBytes(buf []byte) (Data, error)
  • func DataFromMap(raw map[string]interface{}) (Data, error)
• type DataDecoder
  • func GetDataDecoder(name string) (DataDecoder, error)
• type DataEncoder
  • func GetDataEncoder(name string) (DataEncoder, error)
• type DataLauncher
  • func NewDataLauncher(name string, args ...interface{}) (dl DataLauncher, err error)
  • func NewDummyDataLauncher(args ...interface{}) (DataLauncher, error)
  • func NewHttpDataLauncher(args ...interface{}) (DataLauncher, error)
  • func NewHttpxDataLauncher(args ...any) (DataLauncher, error)
• type DataLauncherFactory
• type DummyDataLauncher
  • func (ddl *DummyDataLauncher) Launch(ctx context.Context, src Resource, dat Data) error
• type HttpDataLauncher
  • func (hdl *HttpDataLauncher) Launch(ctx context.Context, src Resource, dat Data) error
• type HttpDataLauncherOption
  • func DefaultHttpDataLauncherOption() *HttpDataLauncherOption
• type HttpxDataLauncher
  • func (x *HttpxDataLauncher) GetLogger() log.FieldLogger
  • func (x *HttpxDataLauncher) Launch(ctx context.Context, src Resource, dat Data) error
• type HttpxDataLauncherOption
• type JsonDataDecoder
  • func (*JsonDataDecoder) Decode(buf []byte) (Data, error)
• type JsonDataEncoder
  • func (*JsonDataEncoder) Encode(dat Data) ([]byte, error)
• type Resource
  • func NewResource(id, typ string) Resource

Constants

const (
	HTTP_HEADER_SOURCE_ID      = "X-Evaluator-Source-ID"
	HTTP_HEADER_SOURCE_TYPE    = "X-Evaluator-Source-Type"
	HTTP_HEADER_DEVICE_ID      = "X-Evaluator-Device-ID"
	HTTP_HEADER_DATA_CODEC     = "X-Evaluator-Data-Codec"
	HTTP_HEADER_DATA_TIMESTAMP = "X-Evaluator-Data-Timestamp"
	HTTP_HEADER_DATA_TAGS      = "X-Evaluator-Data-Tags"
)

const (
	TIMER_DEFAULT_CONFIG = "default"
)

Variables

var (
	ErrUnsupportedDataLauncherFactory = errors.New("unsupported data launcher factory")

	ErrUnsupportedDataEncoder = errors.New("unsupported data encoder")
	ErrUnsupportedDataDecoder = errors.New("unsupported data decoder")
)

Functions

func ExtractDevice

func ExtractDevice(ctx context.Context) string

func ExtractTags

func ExtractTags(ctx context.Context) map[string]string

func ExtractTimestamp

func ExtractTimestamp(ctx context.Context) time.Time

func ExtractToken

func ExtractToken(ctx context.Context) string

func ToData

func ToData(d *Data) func(string, interface{}) error

func WithDevice

func WithDevice(ctx context.Context, dev string) context.Context

func WithTags

func WithTags(ctx context.Context, tags map[string]string) context.Context

func WithTimestamp

func WithTimestamp(ctx context.Context, ts time.Time) context.Context

func WithToken

func WithToken(ctx context.Context, tkn string) context.Context

Types

type Data

type Data interface {
	Iter() map[string]interface{}
	Get(string) interface{}
	With(string, interface{}) Data
}

func DataFromBytes

func DataFromBytes(buf []byte) (Data, error)

func DataFromMap

func DataFromMap(raw map[string]interface{}) (Data, error)

type DataDecoder

type DataDecoder interface {
	Decode([]byte) (Data, error)
}

func GetDataDecoder

func GetDataDecoder(name string) (DataDecoder, error)

type DataEncoder

type DataEncoder interface {
	Encode(Data) ([]byte, error)
}

func GetDataEncoder

func GetDataEncoder(name string) (DataEncoder, error)

type DataLauncher

type DataLauncher interface {
	Launch(context.Context, Resource, Data) error
}

func NewDataLauncher

func NewDataLauncher(name string, args ...interface{}) (dl DataLauncher, err error)

func NewDummyDataLauncher

func NewDummyDataLauncher(args ...interface{}) (DataLauncher, error)

func NewHttpDataLauncher

func NewHttpDataLauncher(args ...interface{}) (DataLauncher, error)

func NewHttpxDataLauncher

func NewHttpxDataLauncher(args ...any) (DataLauncher, error)

type DataLauncherFactory

type DataLauncherFactory func(...interface{}) (DataLauncher, error)

type DummyDataLauncher

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

func (*DummyDataLauncher) Launch

func (ddl *DummyDataLauncher) Launch(ctx context.Context, src Resource, dat Data) error

type HttpDataLauncher

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

func (*HttpDataLauncher) Launch

func (hdl *HttpDataLauncher) Launch(ctx context.Context, src Resource, dat Data) error

type HttpDataLauncherOption

type HttpDataLauncherOption struct {
	Endpoint  string
	DataCodec string
}

func DefaultHttpDataLauncherOption

func DefaultHttpDataLauncherOption() *HttpDataLauncherOption

type HttpxDataLauncher

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

func (*HttpxDataLauncher) GetLogger

func (x *HttpxDataLauncher) GetLogger() log.FieldLogger

func (*HttpxDataLauncher) Launch

func (x *HttpxDataLauncher) Launch(ctx context.Context, src Resource, dat Data) error

type HttpxDataLauncherOption

type HttpxDataLauncherOption struct {
	Endpoint      string
	HeadersTplStr string
	DataCodec     string
}

type JsonDataDecoder

type JsonDataDecoder struct{}

func (*JsonDataDecoder) Decode

func (*JsonDataDecoder) Decode(buf []byte) (Data, error)

type JsonDataEncoder

type JsonDataEncoder struct{}

func (*JsonDataEncoder) Encode

func (*JsonDataEncoder) Encode(dat Data) ([]byte, error)

type Resource

type Resource interface {
	GetId() string
	GetType() string
}

func NewResource

func NewResource(id, typ string) Resource