storage

Documentation

Index

• type MemberStore
• type PgMember
  • func (p PgMember) TableName() string
• type PgSuspicion
  • func (p PgSuspicion) TableName() string
• type PostgresqlStore
  • func NewPostgresqlMemberStore(dsn string) (*PostgresqlStore, error)
  • func (p *PostgresqlStore) Announce(member *cluster.Member) error
  • func (p *PostgresqlStore) DeclareDead(member *cluster.Member) error
  • func (p *PostgresqlStore) DeclareSuspect(accuser, suspect *cluster.Member) error
  • func (p *PostgresqlStore) GetMembers() ([]*cluster.Member, error)
  • func (p *PostgresqlStore) GetSuspicions(member *cluster.Member) ([]cluster.Suspicion, error)
  • func (p *PostgresqlStore) LatestSuspicion(member *cluster.Member) (*cluster.Suspicion, error)
  • func (p *PostgresqlStore) RemoveSuspicions(member *cluster.Member) error

Types

type MemberStore

type MemberStore interface {
	GetMembers() ([]*cluster.Member, error)
	Announce(member *cluster.Member) error
	GetSuspicions(member *cluster.Member) ([]cluster.Suspicion, error)
	RemoveSuspicions(member *cluster.Member) error
	LatestSuspicion(member *cluster.Member) (*cluster.Suspicion, error)
	DeclareDead(member *cluster.Member) error
	DeclareSuspect(accuser, suspect *cluster.Member) error
}

type PgMember

type PgMember struct {
	IP     string `gorm:"primaryKey"`
	Port   int    `gorm:"primaryKey"`
	Epoch  int64
	Grains pq.StringArray `gorm:"type:string[]"`
}

func (PgMember) TableName

func (p PgMember) TableName() string

type PgSuspicion

type PgSuspicion struct {
	SuspectIP   string `gorm:"primaryKey"`
	SuspectPort int    `gorm:"primaryKey"`
	AccuserIP   string `gorm:"primaryKey"`
	AccuserPort int    `gorm:"primaryKey"`
	Timestamp   int64
}

func (PgSuspicion) TableName

func (p PgSuspicion) TableName() string

type PostgresqlStore

type PostgresqlStore struct {
	MemberStore
	// contains filtered or unexported fields
}

func NewPostgresqlMemberStore

func NewPostgresqlMemberStore(dsn string) (*PostgresqlStore, error)

func (*PostgresqlStore) Announce

func (p *PostgresqlStore) Announce(member *cluster.Member) error

func (*PostgresqlStore) DeclareDead

func (p *PostgresqlStore) DeclareDead(member *cluster.Member) error

func (*PostgresqlStore) DeclareSuspect

func (p *PostgresqlStore) DeclareSuspect(accuser, suspect *cluster.Member) error

func (*PostgresqlStore) GetMembers

func (p *PostgresqlStore) GetMembers() ([]*cluster.Member, error)

func (*PostgresqlStore) GetSuspicions

func (p *PostgresqlStore) GetSuspicions(member *cluster.Member) ([]cluster.Suspicion, error)

func (*PostgresqlStore) LatestSuspicion

func (p *PostgresqlStore) LatestSuspicion(member *cluster.Member) (*cluster.Suspicion, error)

func (*PostgresqlStore) RemoveSuspicions

func (p *PostgresqlStore) RemoveSuspicions(member *cluster.Member) error