storage

package
v0.0.0-...-7c85a9a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 22, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL