Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NatsKVPersistence ¶
type NatsKVPersistence struct {
// contains filtered or unexported fields
}
func NewNatsKVPersistence ¶
func NewNatsKVPersistence(cfg natscli.Config) (*NatsKVPersistence, error)
func (*NatsKVPersistence) Get ¶
func (n *NatsKVPersistence) Get(ctx context.Context, key model.StorageKey) (*structpb.Struct, error)
func (*NatsKVPersistence) Set ¶
func (n *NatsKVPersistence) Set(ctx context.Context, key model.StorageKey, value *structpb.Struct) error
type ValkeyStorage ¶
type ValkeyStorage struct {
// contains filtered or unexported fields
}
func NewValkeyStorage ¶
func NewValkeyStorage(valkeyCli valkey.Client) *ValkeyStorage
func (*ValkeyStorage) Get ¶
func (s *ValkeyStorage) Get(ctx context.Context, key model.StorageKey) (*structpb.Struct, error)
func (*ValkeyStorage) Set ¶
func (s *ValkeyStorage) Set(ctx context.Context, key model.StorageKey, value *structpb.Struct) error
Click to show internal directories.
Click to hide internal directories.