Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.

state

package

v1.7.4 Latest Latest Go to latest Published: Sep 2, 2026 License: MIT Imports: 10 Imported by: 0

Details

View Source

const (
	QueryInitTable = "InitTable"
	QueryGet       = "Get"
	QuerySet       = "Set"
	QueryDelete    = "Delete"
)

This section is empty.

func NewEtcdStateStore(endpoints []string, prefix string, timeout time.Duration) (hermod.StateStore, error)

func NewMemoryStore() hermod.StateStore

func NewRedisStateStore(addr, password string, db int, prefix string, ttl time.Duration) hermod.StateStore

func NewSQLiteStateStore(path string) (hermod.StateStore, error)

func NewStateStore(cfg Config) (hermod.StateStore, error)

type Config struct {
	Type     string
	Path     string
	Address  string
	Password string
	DB       int
	Prefix   string
}

type EtcdStateStore struct {
	// contains filtered or unexported fields
}

func (s *EtcdStateStore) Close() error

func (s *EtcdStateStore) Delete(ctx context.Context, key string) error

func (s *EtcdStateStore) Get(ctx context.Context, key string) ([]byte, error)

func (s *EtcdStateStore) Set(ctx context.Context, key string, value []byte) error

type RedisStateStore struct {
	// contains filtered or unexported fields
}

func (s *RedisStateStore) Delete(ctx context.Context, key string) error

func (s *RedisStateStore) Get(ctx context.Context, key string) ([]byte, error)

func (s *RedisStateStore) Set(ctx context.Context, key string, value []byte) error

type SQLiteStateStore struct {
	// contains filtered or unexported fields
}

func (s *SQLiteStateStore) Close() error

func (s *SQLiteStateStore) Delete(ctx context.Context, key string) error

func (s *SQLiteStateStore) Get(ctx context.Context, key string) ([]byte, error)

func (s *SQLiteStateStore) Set(ctx context.Context, key string, value []byte) error