storage

Documentation

Index

• Variables
• type Storage
  • func New(path string) (*Storage, error)
  • func (storage *Storage) ActivateSharedPeer(sharingKey string, pubkey string) (int64, error)
  • func (storage *Storage) AsKeystore() auth.KeyStore
  • func (storage *Storage) CreatePeer(peer types.PeerInfo) (int64, error)
  • func (storage *Storage) DeleteAuthorizerKey(id string) error
  • func (storage *Storage) DeleteEventlogsSubscriber(subscriberID string) error
  • func (storage *Storage) DeletePeer(id int64) error
  • func (storage *Storage) GetAuthorizerKeyByID(id string) (types.AuthorizerKey, error)
  • func (storage *Storage) GetDownstreamMetric() int64
  • func (storage *Storage) GetEventlogsSubscriber(subscriberID string) (*types.EventlogSubscriber, error)
  • func (storage *Storage) GetPeer(id int64) (*types.PeerInfo, error)
  • func (s *Storage) GetPeerBySharingKey(skey string) (types.PeerInfo, error)
  • func (storage *Storage) GetUpstreamMetric() int64
  • func (storage *Storage) ListAuthorizerKeys() ([]types.AuthorizerKey, error)
  • func (storage *Storage) PutEventlogsSubscriber(subscriber *types.EventlogSubscriber) error
  • func (storage *Storage) Running() bool
  • func (storage *Storage) SearchPeers(filter *types.PeerInfo) ([]*types.PeerInfo, error)
  • func (storage *Storage) SetDownstreamMetric(value int64)
  • func (storage *Storage) SetUpstreamMetric(value int64)
  • func (storage *Storage) Shutdown() error
  • func (storage *Storage) UpdateAuthorizerKeys(keys []types.AuthorizerKey) error
  • func (storage *Storage) UpdatePeer(peer *types.PeerInfo) (int64, error)
  • func (storage *Storage) UpdatePeerStats(now time.Time, peer *types.PeerInfo) error

Variables

var ErrNotFound = errors.New("not found")

Types

type Storage

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

func New

func New(path string) (*Storage, error)

func (*Storage) ActivateSharedPeer

func (storage *Storage) ActivateSharedPeer(sharingKey string, pubkey string) (int64, error)

func (*Storage) AsKeystore

func (storage *Storage) AsKeystore() auth.KeyStore

func (*Storage) CreatePeer

func (storage *Storage) CreatePeer(peer types.PeerInfo) (int64, error)

func (*Storage) DeleteAuthorizerKey

func (storage *Storage) DeleteAuthorizerKey(id string) error

func (*Storage) DeleteEventlogsSubscriber

func (storage *Storage) DeleteEventlogsSubscriber(subscriberID string) error

func (*Storage) DeletePeer

func (storage *Storage) DeletePeer(id int64) error

func (*Storage) GetAuthorizerKeyByID

func (storage *Storage) GetAuthorizerKeyByID(id string) (types.AuthorizerKey, error)

func (*Storage) GetDownstreamMetric

func (storage *Storage) GetDownstreamMetric() int64

func (*Storage) GetEventlogsSubscriber

func (storage *Storage) GetEventlogsSubscriber(subscriberID string) (*types.EventlogSubscriber, error)

func (*Storage) GetPeer

func (storage *Storage) GetPeer(id int64) (*types.PeerInfo, error)

func (*Storage) GetPeerBySharingKey

func (s *Storage) GetPeerBySharingKey(skey string) (types.PeerInfo, error)

func (*Storage) GetUpstreamMetric

func (storage *Storage) GetUpstreamMetric() int64

func (*Storage) ListAuthorizerKeys

func (storage *Storage) ListAuthorizerKeys() ([]types.AuthorizerKey, error)

func (*Storage) PutEventlogsSubscriber

func (storage *Storage) PutEventlogsSubscriber(subscriber *types.EventlogSubscriber) error

func (*Storage) Running

func (storage *Storage) Running() bool

func (*Storage) SearchPeers

func (storage *Storage) SearchPeers(filter *types.PeerInfo) ([]*types.PeerInfo, error)

func (*Storage) SetDownstreamMetric

func (storage *Storage) SetDownstreamMetric(value int64)

func (*Storage) SetUpstreamMetric

func (storage *Storage) SetUpstreamMetric(value int64)

func (*Storage) Shutdown

func (storage *Storage) Shutdown() error

func (*Storage) UpdateAuthorizerKeys

func (storage *Storage) UpdateAuthorizerKeys(keys []types.AuthorizerKey) error

UpdateAuthorizerKeys updates or inserts the given keys. The methods do not validate the key content.

func (*Storage) UpdatePeer

func (storage *Storage) UpdatePeer(peer *types.PeerInfo) (int64, error)

func (*Storage) UpdatePeerStats

func (storage *Storage) UpdatePeerStats(now time.Time, peer *types.PeerInfo) error

Update only statistics related peer details