Documentation ¶
Index ¶
- Variables
- type Cache
- type CacheWriter
- type DB
- type EntPluginsRepo
- func (e EntPluginsRepo) List(ctx context.Context) ([]Plugin, error)
- func (e EntPluginsRepo) ModulesForPlugin(ctx context.Context, id uuid.UUID) ([]PluginModule, error)
- func (e EntPluginsRepo) Remove(ctx context.Context, id uuid.UUID) error
- func (e EntPluginsRepo) UpsertModules(ctx context.Context, modules []PluginModule) error
- func (e EntPluginsRepo) UpsertPlugin(ctx context.Context, p Plugin) (pluginID uuid.UUID, err error)
- type EntStateRepository
- type EntryOption
- type EntryOptionFunc
- type InMemoryStore
- type Key
- type Metadata
- type PlainKey
- type Plugin
- type PluginModule
- type Plugins
- type StateCache
- type Store
- type StoreReader
- type StoreWriter
- type StringsKey
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrEmptyKey = errors.New("key may not be empty")
Functions ¶
This section is empty.
Types ¶
type Cache ¶
type Cache interface { CacheWriter StoreReader }
type CacheWriter ¶
type EntPluginsRepo ¶
type EntPluginsRepo struct {
// contains filtered or unexported fields
}
func NewEntPluginsRepo ¶
func NewEntPluginsRepo(client *ent.Client) *EntPluginsRepo
func (EntPluginsRepo) ModulesForPlugin ¶
func (e EntPluginsRepo) ModulesForPlugin(ctx context.Context, id uuid.UUID) ([]PluginModule, error)
func (EntPluginsRepo) UpsertModules ¶
func (e EntPluginsRepo) UpsertModules(ctx context.Context, modules []PluginModule) error
func (EntPluginsRepo) UpsertPlugin ¶
type EntStateRepository ¶
type EntStateRepository struct {
// contains filtered or unexported fields
}
func NewEntStore ¶
func (*EntStateRepository) Set ¶
func (s *EntStateRepository) Set(ctx context.Context, key Key, state []byte, opts ...EntryOption) error
type EntryOption ¶
type EntryOption interface {
// contains filtered or unexported methods
}
func WithTTL ¶
func WithTTL(ttl time.Duration) EntryOption
type EntryOptionFunc ¶
type EntryOptionFunc func(e *ent.KVEntryCreate)
type InMemoryStore ¶
type InMemoryStore struct {
// contains filtered or unexported fields
}
func (*InMemoryStore) Set ¶
func (i *InMemoryStore) Set(_ context.Context, key Key, state []byte, opts ...EntryOption) error
type PluginModule ¶
type Plugins ¶
type Plugins interface { List(ctx context.Context) ([]Plugin, error) Remove(ctx context.Context, id uuid.UUID) error ModulesForPlugin(ctx context.Context, id uuid.UUID) ([]PluginModule, error) UpsertPlugin(ctx context.Context, plugin Plugin) (pluginID uuid.UUID, err error) UpsertModules(ctx context.Context, modules []PluginModule) error }
type StateCache ¶
func NewStateCache ¶
func NewStateCache(ttl time.Duration, store Store) *StateCache
type Store ¶
type Store interface { StoreWriter StoreReader }
type StoreReader ¶
type StoreWriter ¶
type StringsKey ¶
type StringsKey []string
func KeyOfStrings ¶
func KeyOfStrings(parts ...any) StringsKey
func (StringsKey) Bytes ¶
func (k StringsKey) Bytes() []byte
Source Files ¶
Click to show internal directories.
Click to hide internal directories.