metathings_evaluatord_storage

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

type DefaultTimerStorageOption struct {
	IsTraced bool
	Driver   string
	Uri      string
}

type Evaluator struct {
	Id        *string
	CreatedAt time.Time
	UpdatedAt time.Time

	Alias       *string `gorm:"column:alias"`
	Description *string `gorm:"column:description"`
	Config      *string `gorm:"column:config"`

	Sources  []*Resource `gorm:"-"`
	Operator *Operator   `gorm:"-"`
}

type EvaluatorSourceMapping struct {
	CreatedAt time.Time

	EvaluatorId *string `gorm:"column:evaluator_id"`
	SourceId    *string `gorm:"column:source_id"`
	SourceType  *string `gorm:"column:source_type"`
}

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

type Influxdb2TaskStorageOption struct {
	Address string
	Token   string
	Org     string
	Bucket  string
}

type ListTasksBySourceOption func(objx.Map)

type LuaDescriptor struct {
	CreatedAt time.Time

	OperatorId *string `gorm:"column:operator_id"`

	Code *string `gorm:"column:code"`
}

type Operator struct {
	Id        *string
	CreatedAt time.Time
	UpdatedAt time.Time

	EvaluatorId *string `gorm:"column:evaluator_id"`
	Alias       *string `gorm:"column:alias"`
	Description *string `gorm:"column:description"`

	Driver *string `gorm:"column:driver"`

	LuaDescriptor *LuaDescriptor `gorm:"-"`
}

type Resource struct {
	Id   *string
	Type *string
}

type Storage interface {
	CreateEvaluator(context.Context, *Evaluator) (*Evaluator, error)
	DeleteEvaluator(ctx context.Context, id string) error
	PatchEvaluator(ctx context.Context, id string, evaluator *Evaluator) (*Evaluator, error)
	GetEvaluator(ctx context.Context, id string) (*Evaluator, error)
	ListEvaluators(context.Context, *Evaluator) ([]*Evaluator, error)
	ListEvaluatorsBySource(context.Context, *Resource) ([]*Evaluator, error)
	AddSourcesToEvaluator(ctx context.Context, evaluator_id string, sources []*Resource) error
	RemoveSourcesFromEvaluator(ctx context.Context, evaluator_id string, sources []*Resource) error
	ExistEvaluator(context.Context, *Evaluator) (bool, error)
	ExistOperator(context.Context, *Operator) (bool, error)
}

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

type StorageImplOption struct {
	IsTraced bool
}

type Task struct {
	Id        *string
	CreatedAt time.Time
	UpdatedAt time.Time

	CurrentState *TaskState
	Source       *Resource

	States []*TaskState
}

type TaskState struct {
	At    *time.Time
	State *string
	Tags  map[string]interface{}
}

type TaskStorage interface {
	ListTasksBySource(ctx context.Context, src *Resource, opts ...ListTasksBySourceOption) ([]*Task, error)
	GetTask(context.Context, string) (*Task, error)
	PatchTask(context.Context, *Task, *TaskState) error
}

type TaskStorageFactory func(...interface{}) (TaskStorage, error)

type Timer struct {
	Id        *string
	CreatedAt time.Time
	UpdatedAt time.Time

	Alias       *string  `gorm:"column:alias"`
	Description *string  `gorm:"column:description"`
	Schedule    *string  `gorm:"column:schedule"`
	Timezone    *string  `gorm:"column:timezone"`
	Enabled     *bool    `gorm:"column:enabled"`
	Configs     []string `gorm:"-"`
}

type TimerConfigMapping struct {
	CreatedAt time.Time

	TimerId  *string `gorm:"column:timer_id"`
	ConfigId *string `gorm:"column:config_id"`
}

type TimerStorage interface {
	CreateTimer(context.Context, *Timer) (*Timer, error)
	DeleteTimer(context.Context, string) error
	PatchTimer(context.Context, string, *Timer) (*Timer, error)
	GetTimer(context.Context, string) (*Timer, error)
	ListTimers(context.Context, *Timer) ([]*Timer, error)
	AddConfigsToTimer(ctx context.Context, timer_id string, config_ids []string) error
	RemoveConfigsFromTimer(ctx context.Context, timer_id string, config_ids []string) error
	ExistTimer(context.Context, *Timer) (bool, error)
}

type TimerStorageFactory func(...interface{}) (TimerStorage, error)

type TracedStorage struct {
	*opentracing_storage_helper.BaseTracedStorage
	Storage
}

type TracedTimerStorage struct {
	*opentracing_storage_helper.BaseTracedStorage
	TimerStorage
}