peers

Documentation

Index

• Variables
• func NewSQLitePersistence(db *sql.DB) sqlitePersistence
• type MemoryPersistence
  • func NewMemoryPersistence() *MemoryPersistence
  • func (p *MemoryPersistence) Add(groupID state.GroupID, peerID state.PeerID) error
  • func (p *MemoryPersistence) Exists(groupID state.GroupID, peerID state.PeerID) (bool, error)
  • func (p *MemoryPersistence) GetByGroupID(groupID state.GroupID) ([]state.PeerID, error)
• type Persistence

Variables

var (
	ErrPeerNotFound = errors.New("peer not found")
)

Functions

func NewSQLitePersistence

func NewSQLitePersistence(db *sql.DB) sqlitePersistence

Types

type MemoryPersistence

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

func NewMemoryPersistence

func NewMemoryPersistence() *MemoryPersistence

func (*MemoryPersistence) Add

func (p *MemoryPersistence) Add(groupID state.GroupID, peerID state.PeerID) error

func (*MemoryPersistence) Exists

func (p *MemoryPersistence) Exists(groupID state.GroupID, peerID state.PeerID) (bool, error)

func (*MemoryPersistence) GetByGroupID

func (p *MemoryPersistence) GetByGroupID(groupID state.GroupID) ([]state.PeerID, error)

type Persistence

type Persistence interface {
	Add(state.GroupID, state.PeerID) error
	GetByGroupID(group state.GroupID) ([]state.PeerID, error)
	Exists(state.GroupID, state.PeerID) (bool, error)
}