controllers

package
v0.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 7, 2022 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Controllers = map[string]kodex.ControllerMaker{
	"inMemory": MakeInMemoryController,
}

Functions

func MakeInMemoryController

func MakeInMemoryController(config map[string]interface{}, settings kodex.Settings, definitions *kodex.Definitions) (kodex.Controller, error)

func MakeInMemoryStream

func MakeInMemoryStream(id []byte, config map[string]interface{}, project *InMemoryProject) (kodex.Stream, error)

Types

type ActionConfigMap

type ActionConfigMap struct {
	ActionConfig kodex.ActionConfig
}

type InMemoryActionConfig

type InMemoryActionConfig struct {
	kodex.BaseActionConfig
	// contains filtered or unexported fields
}

func MakeInMemoryActionConfig

func MakeInMemoryActionConfig(id []byte, project kodex.Project) *InMemoryActionConfig

func (*InMemoryActionConfig) ActionType

func (c *InMemoryActionConfig) ActionType() string

func (*InMemoryActionConfig) ConfigData

func (c *InMemoryActionConfig) ConfigData() map[string]interface{}

func (*InMemoryActionConfig) CreatedAt

func (c *InMemoryActionConfig) CreatedAt() time.Time

func (*InMemoryActionConfig) Data

func (c *InMemoryActionConfig) Data() interface{}

func (*InMemoryActionConfig) Delete

func (c *InMemoryActionConfig) Delete() error

func (*InMemoryActionConfig) DeletedAt

func (c *InMemoryActionConfig) DeletedAt() *time.Time

func (*InMemoryActionConfig) Description

func (c *InMemoryActionConfig) Description() string

func (*InMemoryActionConfig) ID

func (c *InMemoryActionConfig) ID() []byte

func (*InMemoryActionConfig) Index

func (c *InMemoryActionConfig) Index() int

func (*InMemoryActionConfig) InternalID

func (c *InMemoryActionConfig) InternalID() []byte

func (*InMemoryActionConfig) Name

func (c *InMemoryActionConfig) Name() string

func (*InMemoryActionConfig) Refresh

func (c *InMemoryActionConfig) Refresh() error

func (*InMemoryActionConfig) Save

func (c *InMemoryActionConfig) Save() error

func (*InMemoryActionConfig) SetActionType

func (c *InMemoryActionConfig) SetActionType(actionType string) error

func (*InMemoryActionConfig) SetConfigData

func (c *InMemoryActionConfig) SetConfigData(configData map[string]interface{}) error

func (*InMemoryActionConfig) SetData

func (c *InMemoryActionConfig) SetData(data interface{}) error

func (*InMemoryActionConfig) SetDescription

func (c *InMemoryActionConfig) SetDescription(description string) error

func (*InMemoryActionConfig) SetIndex

func (c *InMemoryActionConfig) SetIndex(index int) error

func (*InMemoryActionConfig) SetName

func (c *InMemoryActionConfig) SetName(name string) error

func (*InMemoryActionConfig) UpdatedAt

func (c *InMemoryActionConfig) UpdatedAt() time.Time

type InMemoryConfig

type InMemoryConfig struct {
	kodex.BaseConfig
	// contains filtered or unexported fields
}

func MakeInMemoryConfig

func MakeInMemoryConfig(stream *InMemoryStream, id []byte, config map[string]interface{}) (*InMemoryConfig, error)

func (*InMemoryConfig) ActionConfigs

func (c *InMemoryConfig) ActionConfigs() ([]kodex.ActionConfig, error)

func (*InMemoryConfig) AddActionConfig

func (c *InMemoryConfig) AddActionConfig(actionConfig kodex.ActionConfig, index int) error

func (*InMemoryConfig) AddDestination

func (c *InMemoryConfig) AddDestination(destination kodex.Destination, name string, status kodex.DestinationStatus) error

func (*InMemoryConfig) CreatedAt

func (c *InMemoryConfig) CreatedAt() time.Time

func (*InMemoryConfig) Data

func (c *InMemoryConfig) Data() interface{}

func (*InMemoryConfig) Delete

func (c *InMemoryConfig) Delete() error

func (*InMemoryConfig) DeletedAt

func (c *InMemoryConfig) DeletedAt() *time.Time

func (*InMemoryConfig) Description

func (c *InMemoryConfig) Description() string

func (*InMemoryConfig) Destinations

func (c *InMemoryConfig) Destinations() (map[string][]kodex.DestinationMap, error)

func (*InMemoryConfig) ID

func (c *InMemoryConfig) ID() []byte

func (*InMemoryConfig) Name

func (c *InMemoryConfig) Name() string

func (*InMemoryConfig) Refresh

func (c *InMemoryConfig) Refresh() error

func (*InMemoryConfig) RemoveActionConfig

func (c *InMemoryConfig) RemoveActionConfig(actionConfig kodex.ActionConfig) error

func (*InMemoryConfig) RemoveDestination

func (c *InMemoryConfig) RemoveDestination(destination kodex.Destination) error

func (*InMemoryConfig) Save

func (c *InMemoryConfig) Save() error

func (*InMemoryConfig) SetData

func (c *InMemoryConfig) SetData(data interface{}) error

func (*InMemoryConfig) SetDescription

func (c *InMemoryConfig) SetDescription(description string) error

func (*InMemoryConfig) SetName

func (c *InMemoryConfig) SetName(name string) error

func (*InMemoryConfig) SetSource

func (c *InMemoryConfig) SetSource(source string) error

func (*InMemoryConfig) SetStatus

func (c *InMemoryConfig) SetStatus(status kodex.ConfigStatus) error

func (*InMemoryConfig) SetVersion

func (c *InMemoryConfig) SetVersion(version string) error

func (*InMemoryConfig) Source

func (c *InMemoryConfig) Source() string

func (*InMemoryConfig) Status

func (c *InMemoryConfig) Status() kodex.ConfigStatus

func (*InMemoryConfig) UpdatedAt

func (c *InMemoryConfig) UpdatedAt() time.Time

func (*InMemoryConfig) Version

func (c *InMemoryConfig) Version() string

type InMemoryController

type InMemoryController struct {
	kodex.BaseController
	// contains filtered or unexported fields
}

func (*InMemoryController) Acquire

func (c *InMemoryController) Acquire(processable kodex.Processable, processorID []byte) (bool, error)

Acquire a processable entity

func (*InMemoryController) ActionConfig

func (c *InMemoryController) ActionConfig(actionConfigID []byte) (kodex.ActionConfig, error)

func (*InMemoryController) ActionConfigs

func (c *InMemoryController) ActionConfigs(filters map[string]interface{}) ([]kodex.ActionConfig, error)

func (*InMemoryController) Begin

func (c *InMemoryController) Begin() error

func (*InMemoryController) Commit

func (c *InMemoryController) Commit() error

func (*InMemoryController) Config

func (c *InMemoryController) Config(configID []byte) (kodex.Config, error)

func (*InMemoryController) DeleteStream added in v0.0.4

func (c *InMemoryController) DeleteStream(stream *InMemoryStream) error

func (*InMemoryController) Destination

func (c *InMemoryController) Destination(destinationID []byte) (kodex.Destination, error)

func (*InMemoryController) Destinations

func (c *InMemoryController) Destinations(filters map[string]interface{}) ([]kodex.Destination, error)

func (*InMemoryController) DestinationsByUrgency

func (c *InMemoryController) DestinationsByUrgency(n int) ([]kodex.DestinationMap, error)

func (*InMemoryController) MakeProject

func (c *InMemoryController) MakeProject(id []byte) kodex.Project

func (*InMemoryController) Ping

func (c *InMemoryController) Ping(processable kodex.Processable, stats kodex.ProcessingStats) error

Send a pingback with stats for a processable entity

func (*InMemoryController) Project

func (c *InMemoryController) Project(id []byte) (kodex.Project, error)

func (*InMemoryController) Projects

func (c *InMemoryController) Projects(filters map[string]interface{}) ([]kodex.Project, error)

func (*InMemoryController) Release

func (c *InMemoryController) Release(processable kodex.Processable, processorID []byte) (bool, error)

Release a processable entity

func (*InMemoryController) ResetDB

func (c *InMemoryController) ResetDB() error

func (*InMemoryController) Rollback

func (c *InMemoryController) Rollback() error

func (*InMemoryController) SaveActionConfig

func (c *InMemoryController) SaveActionConfig(actionConfig kodex.ActionConfig) error

func (*InMemoryController) SaveDestination

func (c *InMemoryController) SaveDestination(destination kodex.Destination) error

func (*InMemoryController) SaveProject

func (c *InMemoryController) SaveProject(project kodex.Project) error

func (*InMemoryController) SaveSource

func (c *InMemoryController) SaveSource(source kodex.Source) error

func (*InMemoryController) SaveStream

func (c *InMemoryController) SaveStream(stream kodex.Stream) error

func (*InMemoryController) Source

func (c *InMemoryController) Source(sourceID []byte) (kodex.Source, error)

func (*InMemoryController) Sources

func (c *InMemoryController) Sources(filters map[string]interface{}) ([]kodex.Source, error)

func (*InMemoryController) SourcesByUrgency

func (c *InMemoryController) SourcesByUrgency(n int) ([]kodex.SourceMap, error)

func (*InMemoryController) Stream

func (c *InMemoryController) Stream(streamID []byte) (kodex.Stream, error)

func (*InMemoryController) Streams

func (c *InMemoryController) Streams(filters map[string]interface{}) ([]kodex.Stream, error)

Return a list of streams identified by the list of IDs and in addition filtered by the given arguments

func (*InMemoryController) StreamsByUrgency

func (c *InMemoryController) StreamsByUrgency(n int) ([]kodex.Stream, error)

type InMemoryDestination

type InMemoryDestination struct {
	kodex.BaseDestination
	// contains filtered or unexported fields
}

func MakeInMemoryDestination

func MakeInMemoryDestination(id []byte, project kodex.Project) *InMemoryDestination

func (*InMemoryDestination) ConfigData

func (i *InMemoryDestination) ConfigData() map[string]interface{}

func (*InMemoryDestination) CreatedAt

func (i *InMemoryDestination) CreatedAt() time.Time

func (*InMemoryDestination) Data

func (i *InMemoryDestination) Data() interface{}

func (*InMemoryDestination) Delete

func (i *InMemoryDestination) Delete() error

func (*InMemoryDestination) DeletedAt

func (i *InMemoryDestination) DeletedAt() *time.Time

func (*InMemoryDestination) Description

func (i *InMemoryDestination) Description() string

func (*InMemoryDestination) DestinationType

func (i *InMemoryDestination) DestinationType() string

func (*InMemoryDestination) ID

func (i *InMemoryDestination) ID() []byte

func (*InMemoryDestination) InternalID

func (i *InMemoryDestination) InternalID() []byte

func (*InMemoryDestination) Name

func (i *InMemoryDestination) Name() string

func (*InMemoryDestination) Refresh

func (i *InMemoryDestination) Refresh() error

func (*InMemoryDestination) Save

func (i *InMemoryDestination) Save() error

func (*InMemoryDestination) SetConfigData

func (i *InMemoryDestination) SetConfigData(configData map[string]interface{}) error

func (*InMemoryDestination) SetData

func (i *InMemoryDestination) SetData(data interface{}) error

func (*InMemoryDestination) SetDescription

func (i *InMemoryDestination) SetDescription(description string) error

func (*InMemoryDestination) SetDestinationType

func (i *InMemoryDestination) SetDestinationType(destinationType string) error

func (*InMemoryDestination) SetName

func (i *InMemoryDestination) SetName(name string) error

func (*InMemoryDestination) UpdatedAt

func (i *InMemoryDestination) UpdatedAt() time.Time

type InMemoryDestinationMap

type InMemoryDestinationMap struct {
	kodex.BaseDestinationMap
	// contains filtered or unexported fields
}

func MakeInMemoryDestinationMap

func MakeInMemoryDestinationMap(id []byte, name string, config *InMemoryConfig, destination *InMemoryDestination, status kodex.DestinationStatus) *InMemoryDestinationMap

func (*InMemoryDestinationMap) Config

func (i *InMemoryDestinationMap) Config() kodex.Config

func (*InMemoryDestinationMap) CreatedAt

func (i *InMemoryDestinationMap) CreatedAt() time.Time

func (*InMemoryDestinationMap) Delete

func (i *InMemoryDestinationMap) Delete() error

func (*InMemoryDestinationMap) DeletedAt

func (i *InMemoryDestinationMap) DeletedAt() *time.Time

func (*InMemoryDestinationMap) Destination

func (i *InMemoryDestinationMap) Destination() kodex.Destination

func (*InMemoryDestinationMap) ID

func (i *InMemoryDestinationMap) ID() []byte

func (*InMemoryDestinationMap) Name

func (i *InMemoryDestinationMap) Name() string

func (*InMemoryDestinationMap) Priority

func (i *InMemoryDestinationMap) Priority() float64

func (*InMemoryDestinationMap) PriorityTime

func (i *InMemoryDestinationMap) PriorityTime() time.Time

func (*InMemoryDestinationMap) Refresh

func (i *InMemoryDestinationMap) Refresh() error

func (*InMemoryDestinationMap) Save

func (i *InMemoryDestinationMap) Save() error

func (*InMemoryDestinationMap) SetConfig

func (i *InMemoryDestinationMap) SetConfig(config kodex.Config) error

func (*InMemoryDestinationMap) SetDestination

func (i *InMemoryDestinationMap) SetDestination(destination kodex.Destination) error

func (*InMemoryDestinationMap) SetName

func (i *InMemoryDestinationMap) SetName(name string) error

func (*InMemoryDestinationMap) SetPriority

func (i *InMemoryDestinationMap) SetPriority(value float64) error

func (*InMemoryDestinationMap) SetPriorityAndTime

func (i *InMemoryDestinationMap) SetPriorityAndTime(value float64, t time.Time) error

func (*InMemoryDestinationMap) SetPriorityTime

func (i *InMemoryDestinationMap) SetPriorityTime(t time.Time) error

func (*InMemoryDestinationMap) SetStatus

func (i *InMemoryDestinationMap) SetStatus(status kodex.DestinationStatus) error

func (*InMemoryDestinationMap) Status

func (*InMemoryDestinationMap) UpdatedAt

func (i *InMemoryDestinationMap) UpdatedAt() time.Time

type InMemoryProject

type InMemoryProject struct {
	kodex.BaseProject
	// contains filtered or unexported fields
}

func MakeInMemoryProject

func MakeInMemoryProject(id []byte, controller kodex.Controller) *InMemoryProject

func (*InMemoryProject) CreatedAt

func (i *InMemoryProject) CreatedAt() time.Time

func (*InMemoryProject) Data

func (i *InMemoryProject) Data() interface{}

func (*InMemoryProject) Delete

func (i *InMemoryProject) Delete() error

func (*InMemoryProject) DeletedAt

func (i *InMemoryProject) DeletedAt() *time.Time

func (*InMemoryProject) Description

func (i *InMemoryProject) Description() string

func (*InMemoryProject) ID

func (i *InMemoryProject) ID() []byte

func (*InMemoryProject) InternalID

func (i *InMemoryProject) InternalID() []byte

func (*InMemoryProject) MakeActionConfig

func (c *InMemoryProject) MakeActionConfig(id []byte) kodex.ActionConfig

func (*InMemoryProject) MakeDestination

func (c *InMemoryProject) MakeDestination(id []byte) kodex.Destination

func (*InMemoryProject) MakeSource

func (c *InMemoryProject) MakeSource(id []byte) kodex.Source

func (*InMemoryProject) MakeStream

func (c *InMemoryProject) MakeStream(id []byte) kodex.Stream

func (*InMemoryProject) Name

func (i *InMemoryProject) Name() string

func (*InMemoryProject) Refresh

func (i *InMemoryProject) Refresh() error

func (*InMemoryProject) Save

func (i *InMemoryProject) Save() error

func (*InMemoryProject) SetData

func (i *InMemoryProject) SetData(data interface{}) error

func (*InMemoryProject) SetDescription

func (i *InMemoryProject) SetDescription(description string) error

func (*InMemoryProject) SetName

func (i *InMemoryProject) SetName(name string) error

func (*InMemoryProject) UpdatedAt

func (i *InMemoryProject) UpdatedAt() time.Time

type InMemorySource

type InMemorySource struct {
	kodex.BaseSource
	// contains filtered or unexported fields
}

func MakeInMemorySource

func MakeInMemorySource(id []byte,
	project kodex.Project) *InMemorySource

func (*InMemorySource) ConfigData

func (i *InMemorySource) ConfigData() map[string]interface{}

func (*InMemorySource) CreatedAt

func (i *InMemorySource) CreatedAt() time.Time

func (*InMemorySource) Data

func (i *InMemorySource) Data() interface{}

func (*InMemorySource) Delete

func (i *InMemorySource) Delete() error

func (*InMemorySource) DeletedAt

func (i *InMemorySource) DeletedAt() *time.Time

func (*InMemorySource) Description

func (i *InMemorySource) Description() string

func (*InMemorySource) ID

func (i *InMemorySource) ID() []byte

func (*InMemorySource) InternalID

func (c *InMemorySource) InternalID() []byte

func (*InMemorySource) Name

func (i *InMemorySource) Name() string

func (*InMemorySource) Refresh

func (i *InMemorySource) Refresh() error

func (*InMemorySource) Save

func (i *InMemorySource) Save() error

func (*InMemorySource) Service

func (i *InMemorySource) Service() kodex.Service

func (*InMemorySource) SetConfigData

func (i *InMemorySource) SetConfigData(configData map[string]interface{}) error

func (*InMemorySource) SetData

func (i *InMemorySource) SetData(data interface{}) error

func (*InMemorySource) SetDescription

func (i *InMemorySource) SetDescription(description string) error

func (*InMemorySource) SetName

func (i *InMemorySource) SetName(name string) error

func (*InMemorySource) SetService

func (i *InMemorySource) SetService(kodex.Service) error

func (*InMemorySource) SetSourceType

func (i *InMemorySource) SetSourceType(sourceType string) error

func (*InMemorySource) SourceType

func (i *InMemorySource) SourceType() string

func (*InMemorySource) Streams

func (i *InMemorySource) Streams(status kodex.SourceStatus) ([]kodex.Stream, error)

func (*InMemorySource) UpdatedAt

func (i *InMemorySource) UpdatedAt() time.Time

type InMemorySourceMap

type InMemorySourceMap struct {
	kodex.BaseSourceMap
	// contains filtered or unexported fields
}

func MakeInMemorySourceMap

func MakeInMemorySourceMap(id []byte, stream *InMemoryStream, source *InMemorySource, status kodex.SourceStatus) *InMemorySourceMap

func (*InMemorySourceMap) CreatedAt

func (i *InMemorySourceMap) CreatedAt() time.Time

func (*InMemorySourceMap) Delete

func (i *InMemorySourceMap) Delete() error

func (*InMemorySourceMap) DeletedAt

func (i *InMemorySourceMap) DeletedAt() *time.Time

func (*InMemorySourceMap) ID

func (i *InMemorySourceMap) ID() []byte

func (*InMemorySourceMap) Priority

func (i *InMemorySourceMap) Priority() float64

func (*InMemorySourceMap) PriorityTime

func (i *InMemorySourceMap) PriorityTime() time.Time

func (*InMemorySourceMap) Refresh

func (i *InMemorySourceMap) Refresh() error

func (*InMemorySourceMap) Save

func (i *InMemorySourceMap) Save() error

func (*InMemorySourceMap) Session

func (i *InMemorySourceMap) Session() interface{}

func (*InMemorySourceMap) SetPriority

func (i *InMemorySourceMap) SetPriority(value float64) error

func (*InMemorySourceMap) SetPriorityAndTime

func (i *InMemorySourceMap) SetPriorityAndTime(value float64, t time.Time) error

func (*InMemorySourceMap) SetPriorityTime

func (i *InMemorySourceMap) SetPriorityTime(t time.Time) error

func (*InMemorySourceMap) SetSession

func (i *InMemorySourceMap) SetSession(session interface{}) error

func (*InMemorySourceMap) SetSource

func (i *InMemorySourceMap) SetSource(source kodex.Source) error

func (*InMemorySourceMap) SetStatus

func (i *InMemorySourceMap) SetStatus(status kodex.SourceStatus) error

func (*InMemorySourceMap) SetStream

func (i *InMemorySourceMap) SetStream(stream kodex.Stream) error

func (*InMemorySourceMap) Source

func (i *InMemorySourceMap) Source() kodex.Source

func (*InMemorySourceMap) Status

func (i *InMemorySourceMap) Status() kodex.SourceStatus

func (*InMemorySourceMap) Stream

func (i *InMemorySourceMap) Stream() kodex.Stream

func (*InMemorySourceMap) UpdatedAt

func (i *InMemorySourceMap) UpdatedAt() time.Time

type InMemoryStream

type InMemoryStream struct {
	kodex.BaseStream
	// contains filtered or unexported fields
}

func (*InMemoryStream) AddSource

func (c *InMemoryStream) AddSource(source kodex.Source, status kodex.SourceStatus) error

func (*InMemoryStream) Config

func (c *InMemoryStream) Config(name string) (kodex.Config, error)

func (*InMemoryStream) Configs

func (c *InMemoryStream) Configs() ([]kodex.Config, error)

func (*InMemoryStream) CreatedAt

func (i *InMemoryStream) CreatedAt() time.Time

func (*InMemoryStream) Data

func (c *InMemoryStream) Data() interface{}

func (*InMemoryStream) Delete

func (i *InMemoryStream) Delete() error

func (*InMemoryStream) DeleteConfig

func (c *InMemoryStream) DeleteConfig(dc *InMemoryConfig) error

func (*InMemoryStream) DeletedAt

func (i *InMemoryStream) DeletedAt() *time.Time

func (*InMemoryStream) Description

func (i *InMemoryStream) Description() string

func (*InMemoryStream) ID

func (c *InMemoryStream) ID() []byte

func (*InMemoryStream) InternalID

func (c *InMemoryStream) InternalID() []byte

func (*InMemoryStream) MakeConfig

func (c *InMemoryStream) MakeConfig(id []byte) kodex.Config

func (*InMemoryStream) Name

func (i *InMemoryStream) Name() string

func (*InMemoryStream) Priority

func (i *InMemoryStream) Priority() float64

func (*InMemoryStream) PriorityTime

func (i *InMemoryStream) PriorityTime() time.Time

func (*InMemoryStream) Refresh

func (i *InMemoryStream) Refresh() error

func (*InMemoryStream) RemoveSource

func (c *InMemoryStream) RemoveSource(source kodex.Source) error

func (*InMemoryStream) Save

func (i *InMemoryStream) Save() error

func (*InMemoryStream) SaveConfig

func (c *InMemoryStream) SaveConfig(config kodex.Config) error

func (*InMemoryStream) SetData

func (c *InMemoryStream) SetData(data interface{}) error

func (*InMemoryStream) SetDescription

func (i *InMemoryStream) SetDescription(description string) error

func (*InMemoryStream) SetName

func (i *InMemoryStream) SetName(name string) error

func (*InMemoryStream) SetPriority

func (i *InMemoryStream) SetPriority(value float64) error

func (*InMemoryStream) SetPriorityAndTime

func (i *InMemoryStream) SetPriorityAndTime(value float64, t time.Time) error

func (*InMemoryStream) SetPriorityTime

func (i *InMemoryStream) SetPriorityTime(t time.Time) error

func (*InMemoryStream) SetStatus

func (i *InMemoryStream) SetStatus(status kodex.StreamStatus) error

func (*InMemoryStream) Sources

func (c *InMemoryStream) Sources() (map[string]kodex.SourceMap, error)

func (*InMemoryStream) Status

func (i *InMemoryStream) Status() kodex.StreamStatus

func (*InMemoryStream) UpdatedAt

func (i *InMemoryStream) UpdatedAt() time.Time

type ProcessorStats

type ProcessorStats struct {
	ProcessorID    []byte
	IdleFraction   float64
	ItemsProcessed int64
	Capacity       float64
}

type Stats

type Stats struct {
	ProcessorStats []ProcessorStats
}

Jump to

Keyboard shortcuts

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