controllers

package
v0.1.14 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2023 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) SetCreatedAt added in v0.1.0 

func (c *InMemoryActionConfig) SetCreatedAt(t time.Time) error

func (*InMemoryActionConfig) SetData 

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

func (*InMemoryActionConfig) SetDeletedAt added in v0.1.0 

func (c *InMemoryActionConfig) SetDeletedAt(t *time.Time) 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) SetUpdatedAt added in v0.1.0 

func (c *InMemoryActionConfig) SetUpdatedAt(t time.Time) 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 (i *InMemoryConfig) CreatedAt() time.Time

func (*InMemoryConfig) Data 

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

func (*InMemoryConfig) Delete 

func (c *InMemoryConfig) Delete() error

func (*InMemoryConfig) DeletedAt 

func (i *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) SetCreatedAt added in v0.1.0 

func (i *InMemoryConfig) SetCreatedAt(t time.Time) error

func (*InMemoryConfig) SetData 

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

func (*InMemoryConfig) SetDeletedAt added in v0.1.0 

func (i *InMemoryConfig) SetDeletedAt(t *time.Time) 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) SetUpdatedAt added in v0.1.0 

func (i *InMemoryConfig) SetUpdatedAt(t time.Time) 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 (i *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) Clone added in v0.1.0 

func (c *InMemoryController) Clone() (kodex.Controller, error)

func (*InMemoryController) Commit 

func (c *InMemoryController) Commit() error

func (*InMemoryController) Config 

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

func (*InMemoryController) Connect added in v0.1.0 

func (c *InMemoryController) Connect() error

func (*InMemoryController) Dataset added in v0.1.0 

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

func (*InMemoryController) Datasets added in v0.1.0 

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

func (*InMemoryController) DeleteActionConfig added in v0.1.0 

func (c *InMemoryController) DeleteActionConfig(actionConfig *InMemoryActionConfig) error

func (*InMemoryController) DeleteDestination added in v0.1.0 

func (c *InMemoryController) DeleteDestination(destination *InMemoryDestination) error

func (*InMemoryController) DeleteProject added in v0.1.0 

func (c *InMemoryController) DeleteProject(project *InMemoryProject) 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) SaveDataset added in v0.1.0 

func (c *InMemoryController) SaveDataset(dataset kodex.Dataset) 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 InMemoryDataset added in v0.1.0 

type InMemoryDataset struct {
	kodex.BaseDataset
	// contains filtered or unexported fields
}

func MakeInMemoryDataset added in v0.1.0 

func MakeInMemoryDataset(id []byte, project kodex.Project) *InMemoryDataset

func (*InMemoryDataset) CreatedAt added in v0.1.0 

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

func (*InMemoryDataset) Data added in v0.1.0 

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

func (*InMemoryDataset) Delete added in v0.1.0 

func (c *InMemoryDataset) Delete() error

func (*InMemoryDataset) DeletedAt added in v0.1.0 

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

func (*InMemoryDataset) Description added in v0.1.0 

func (c *InMemoryDataset) Description() string

func (*InMemoryDataset) ID added in v0.1.0 

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

func (*InMemoryDataset) Index added in v0.1.0 

func (c *InMemoryDataset) Index() int

func (*InMemoryDataset) InternalID added in v0.1.0 

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

func (*InMemoryDataset) Items added in v0.1.0 

func (c *InMemoryDataset) Items() []map[string]any

func (*InMemoryDataset) Name added in v0.1.0 

func (c *InMemoryDataset) Name() string

func (*InMemoryDataset) Refresh added in v0.1.0 

func (c *InMemoryDataset) Refresh() error

func (*InMemoryDataset) Save added in v0.1.0 

func (c *InMemoryDataset) Save() error

func (*InMemoryDataset) SetCreatedAt added in v0.1.0 

func (c *InMemoryDataset) SetCreatedAt(t time.Time) error

func (*InMemoryDataset) SetData added in v0.1.0 

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

func (*InMemoryDataset) SetDeletedAt added in v0.1.0 

func (c *InMemoryDataset) SetDeletedAt(t *time.Time) error

func (*InMemoryDataset) SetDescription added in v0.1.0 

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

func (*InMemoryDataset) SetIndex added in v0.1.0 

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

func (*InMemoryDataset) SetItems added in v0.1.0 

func (c *InMemoryDataset) SetItems(items []map[string]any) error

func (*InMemoryDataset) SetName added in v0.1.0 

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

func (*InMemoryDataset) SetUpdatedAt added in v0.1.0 

func (c *InMemoryDataset) SetUpdatedAt(t time.Time) error

func (*InMemoryDataset) UpdatedAt added in v0.1.0 

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

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) SetCreatedAt added in v0.1.0 

func (i *InMemoryDestination) SetCreatedAt(t time.Time) error

func (*InMemoryDestination) SetData 

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

func (*InMemoryDestination) SetDeletedAt added in v0.1.0 

func (i *InMemoryDestination) SetDeletedAt(t *time.Time) 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) SetUpdatedAt added in v0.1.0 

func (i *InMemoryDestination) SetUpdatedAt(t time.Time) 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 (i *InMemoryDestinationMap) Status() kodex.DestinationStatus

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) MakeDataset added in v0.1.0 

func (c *InMemoryProject) MakeDataset(id []byte) kodex.Dataset

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) SetCreatedAt added in v0.1.0 

func (i *InMemoryProject) SetCreatedAt(t time.Time) error

func (*InMemoryProject) SetData 

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

func (*InMemoryProject) SetDeletedAt added in v0.1.0 

func (i *InMemoryProject) SetDeletedAt(t *time.Time) error

func (*InMemoryProject) SetDescription 

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

func (*InMemoryProject) SetName 

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

func (*InMemoryProject) SetUpdatedAt added in v0.1.0 

func (i *InMemoryProject) SetUpdatedAt(t time.Time) 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) SetCreatedAt added in v0.1.0 

func (i *InMemorySource) SetCreatedAt(t time.Time) error

func (*InMemorySource) SetData 

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

func (*InMemorySource) SetDeletedAt added in v0.1.0 

func (i *InMemorySource) SetDeletedAt(t *time.Time) 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) SetUpdatedAt added in v0.1.0 

func (i *InMemorySource) SetUpdatedAt(t time.Time) 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(id []byte) (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) SetCreatedAt added in v0.1.0 

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

func (*InMemoryStream) SetData 

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

func (*InMemoryStream) SetDeletedAt added in v0.1.0 

func (i *InMemoryStream) SetDeletedAt(t *time.Time) 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) SetUpdatedAt added in v0.1.0 

func (i *InMemoryStream) SetUpdatedAt(t time.Time) 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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.