txstore

Documentation

Index

• type Store
  • func NewStore(homeDir string, logger logrus.FieldLogger) *Store
  • func (s *Store) Close() error
  • func (s *Store) DeleteTx(ctx context.Context, txId string) error
  • func (s *Store) IterateAll(ctx context.Context, cb func(tx *cluster.Transaction)) error
  • func (s *Store) Open() error
  • func (s *Store) SetUmarshalFn(fn unmarshalFn)
  • func (s *Store) StoreTx(ctx context.Context, tx *cluster.Transaction) error

Types

type Store

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

func NewStore

func NewStore(homeDir string, logger logrus.FieldLogger) *Store

func (*Store) Close

func (s *Store) Close() error

func (*Store) DeleteTx

func (s *Store) DeleteTx(ctx context.Context, txId string) error

func (*Store) IterateAll

func (s *Store) IterateAll(ctx context.Context,
	cb func(tx *cluster.Transaction),
) error

func (*Store) Open

func (s *Store) Open() error

func (*Store) SetUmarshalFn

func (s *Store) SetUmarshalFn(fn unmarshalFn)

func (*Store) StoreTx

func (s *Store) StoreTx(ctx context.Context, tx *cluster.Transaction) error