unpublished

Documentation

Index

• type Store
  • func New(provider storage.Provider, unpublishedOperationLifespan time.Duration, ...) (*Store, error)
  • func (s *Store) Delete(op *operation.AnchoredOperation) error
  • func (s *Store) DeleteAll(ops []*operation.AnchoredOperation) error
  • func (s *Store) Get(suffix string) ([]*operation.AnchoredOperation, error)
  • func (s *Store) Put(op *operation.AnchoredOperation) error

Types

type Store

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

Store implements storage for unpublished operation.

func New

func New(provider storage.Provider, unpublishedOperationLifespan time.Duration,
	expiryService *expiry.Service, metrics metricsProvider,
) (*Store, error)

New returns a new instance of an unpublished operation store. This method will also register the unpublished operation store with the given expiry service which will then take care of deleting expired data automatically. Note that it's the caller's responsibility to start the expiry service. unpublishedOperationLifespan defines how long unpublished operations can stay in the store before being flagged for deletion.

func (*Store) Delete

func (s *Store) Delete(op *operation.AnchoredOperation) error

Delete will delete unpublished operation for suffix.

func (*Store) DeleteAll

func (s *Store) DeleteAll(ops []*operation.AnchoredOperation) error

DeleteAll deletes all operations for suffixes.

func (*Store) Get

func (s *Store) Get(suffix string) ([]*operation.AnchoredOperation, error)

Get retrieves unpublished operations by suffix.

func (*Store) Put

func (s *Store) Put(op *operation.AnchoredOperation) error

Put saves an unpublished operation. If it already exists it will be overwritten.