entity

Documentation

Index

• type KeyValueConfiguration
• type KeyValueStoreScope
• type ObjectStore
  • func (o *ObjectStore) Validate() error
• type ObjectStoreScope
• type Process
  • func (n *Process) Validate() error
• type ProcessStreamConfig
• type ProcessesObjectStoresConfig
• type ProcessesStreamConfig
• type StreamConfig
• type VersionKeyValueStores
• type Workflow
  • func (w Workflow) Validate() error
• type WorkflowKeyValueStores
• type WorkflowObjectStoresConfig
• type WorkflowsObjectStoresConfig
• type WorkflowsStreamsConfig

Types

type KeyValueConfiguration

type KeyValueConfiguration struct {
	KeyValueStore string
	Configuration map[string]string
}

type KeyValueStoreScope

type KeyValueStoreScope string

const (
	KVScopeGlobal   KeyValueStoreScope = "global"
	KVScopeVersion  KeyValueStoreScope = "version"
	KVScopeWorkflow KeyValueStoreScope = "workflow"
	KVScopeProcess  KeyValueStoreScope = "process"
)

type ObjectStore

type ObjectStore struct {
	Name  string
	Scope ObjectStoreScope
}

func (*ObjectStore) Validate

func (o *ObjectStore) Validate() error

type ObjectStoreScope

type ObjectStoreScope string

const (
	ObjStoreScopeUndefined ObjectStoreScope = "undefined"
	ObjStoreScopeWorkflow  ObjectStoreScope = "workflow"
	ObjStoreScopeProject   ObjectStoreScope = "project"
)

type Process

type Process struct {
	Name          string
	Subscriptions []string
	ObjectStore   *ObjectStore
}

func (*Process) Validate

func (n *Process) Validate() error

type ProcessStreamConfig

type ProcessStreamConfig struct {
	Subject       string
	Subscriptions []string
}

type ProcessesObjectStoresConfig

type ProcessesObjectStoresConfig map[string]string

type ProcessesStreamConfig

type ProcessesStreamConfig map[string]ProcessStreamConfig

type StreamConfig

type StreamConfig struct {
	Stream    string
	Processes ProcessesStreamConfig
}

type VersionKeyValueStores

type VersionKeyValueStores struct {
	ProjectStore    string
	WorkflowsStores map[string]*WorkflowKeyValueStores
}

type Workflow

type Workflow struct {
	Name      string
	Processes []Process
}

func (Workflow) Validate

func (w Workflow) Validate() error

type WorkflowKeyValueStores

type WorkflowKeyValueStores struct {
	WorkflowStore string
	Processes     map[string]string
}

type WorkflowObjectStoresConfig

type WorkflowObjectStoresConfig struct {
	Processes ProcessesObjectStoresConfig
}

type WorkflowsObjectStoresConfig

type WorkflowsObjectStoresConfig map[string]*WorkflowObjectStoresConfig

type WorkflowsStreamsConfig

type WorkflowsStreamsConfig map[string]*StreamConfig