interfaces

Documentation

Index

• type NatsClient
• type NatsManager

Types

type NatsClient

type NatsClient interface {
	GetObjectStoreNames(optFilter ...*regexp.Regexp) ([]string, error)
	GetStreamNames(optFilter ...*regexp.Regexp) ([]string, error)
	CreateStream(streamConfig *entity.StreamConfig) error
	CreateObjectStore(objectStore string) error
	CreateKeyValueStore(keyValueStore string) error
	UpdateConfiguration(keyValueStore string, keyValueConfig map[string]string) error
	DeleteStream(stream string) error
	DeleteObjectStore(stream string) error
	DeleteKeyValueStore(keyValueStore string) error
}

type NatsManager

type NatsManager interface {
	CreateStreams(productID, versionTag string, workflows []entity.Workflow) (entity.WorkflowsStreamsConfig, error)
	CreateObjectStores(productID, versionTag string, workflows []entity.Workflow) (entity.WorkflowsObjectStoresConfig, error)
	CreateVersionKeyValueStores(productID, versionTag string, workflows []entity.Workflow) (*entity.VersionKeyValueStores, error)
	CreateGlobalKeyValueStore(productID string) (string, error)
	UpdateKeyValueStoresConfiguration(configurations []entity.KeyValueConfiguration) error
	DeleteStreams(productID, versionTag string) error
	DeleteObjectStores(productID, versionTag string) error
	DeleteVersionKeyValueStores(productID, versionTag string, workflows []entity.Workflow) error
	DeleteGlobalKeyValueStore(productID string) error
}