syncerutil

Documentation

Index

• type EphemeralPeerStore
  • func NewEphemeralPeerStore() *EphemeralPeerStore
  • func (eps *EphemeralPeerStore) AddPeer(addr string) error
  • func (eps *EphemeralPeerStore) Ban(addr string, duration time.Duration, reason string) error
  • func (eps *EphemeralPeerStore) Banned(addr string) (bool, error)
  • func (eps *EphemeralPeerStore) PeerInfo(peer string) (syncer.PeerInfo, bool)
  • func (eps *EphemeralPeerStore) Peers() ([]syncer.PeerInfo, error)
  • func (eps *EphemeralPeerStore) UpdatePeerInfo(addr string, fn func(*syncer.PeerInfo)) error
• type JSONPeerStore
  • func NewJSONPeerStore(path string) (*JSONPeerStore, error)
  • func (jps *JSONPeerStore) AddPeer(addr string) error
  • func (jps *JSONPeerStore) Ban(addr string, duration time.Duration, reason string) error
  • func (jps *JSONPeerStore) UpdatePeerInfo(addr string, fn func(*syncer.PeerInfo)) error

Types

type EphemeralPeerStore

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

EphemeralPeerStore implements PeerStore with an in-memory map.

func NewEphemeralPeerStore

func NewEphemeralPeerStore() *EphemeralPeerStore

NewEphemeralPeerStore initializes an EphemeralPeerStore.

func (*EphemeralPeerStore) AddPeer

func (eps *EphemeralPeerStore) AddPeer(addr string) error

AddPeer implements PeerStore.

func (*EphemeralPeerStore) Ban

func (eps *EphemeralPeerStore) Ban(addr string, duration time.Duration, reason string) error

Ban implements PeerStore.

func (*EphemeralPeerStore) Banned

func (eps *EphemeralPeerStore) Banned(addr string) (bool, error)

Banned implements PeerStore.

func (*EphemeralPeerStore) PeerInfo

func (eps *EphemeralPeerStore) PeerInfo(peer string) (syncer.PeerInfo, bool)

PeerInfo implements PeerStore.

func (*EphemeralPeerStore) Peers

func (eps *EphemeralPeerStore) Peers() ([]syncer.PeerInfo, error)

Peers implements PeerStore.

func (*EphemeralPeerStore) UpdatePeerInfo

func (eps *EphemeralPeerStore) UpdatePeerInfo(addr string, fn func(*syncer.PeerInfo)) error

UpdatePeerInfo implements PeerStore.

type JSONPeerStore

type JSONPeerStore struct {
	*EphemeralPeerStore
	// contains filtered or unexported fields
}

JSONPeerStore implements PeerStore with a JSON file on disk.

func NewJSONPeerStore

func NewJSONPeerStore(path string) (*JSONPeerStore, error)

NewJSONPeerStore returns a JSONPeerStore backed by the specified file.

func (*JSONPeerStore) AddPeer

func (jps *JSONPeerStore) AddPeer(addr string) error

AddPeer implements PeerStore.

func (*JSONPeerStore) Ban

func (jps *JSONPeerStore) Ban(addr string, duration time.Duration, reason string) error

Ban implements PeerStore.

func (*JSONPeerStore) UpdatePeerInfo

func (jps *JSONPeerStore) UpdatePeerInfo(addr string, fn func(*syncer.PeerInfo)) error

UpdatePeerInfo implements PeerStore.