topo

Documentation

Index

• Constants
• func ClusterDir(clusterName string) string
• func GroupDir(clusterName string) string
• func GroupPath(clusterName string, gid int) string
• func LockPath(clusterName string) string
• func OraclePath(clusterName string) string
• func TimestampPath(clusterName string) string
• type Cluster
• type Group
  • func (g *Group) Encode() []byte
• type Oracle
  • func (o *Oracle) Encode() []byte
• type Store
  • func NewStore(client client.Client, clusterName string) *Store
  • func (s *Store) Acquire() error
  • func (s *Store) Client() client.Client
  • func (s *Store) Close() error
  • func (s *Store) DeleteGroup(gid int) error
  • func (s *Store) DeleteTimestamp() error
  • func (s *Store) GetLocalIP() (string, error)
  • func (s *Store) GroupDir() string
  • func (s *Store) GroupPath(gid int) string
  • func (s *Store) ListGroup() (map[int]*Group, error)
  • func (s *Store) LoadGroup(gid int, must bool) (*Group, error)
  • func (s *Store) LoadOracle() (*Oracle, error)
  • func (s *Store) LoadTimestamp() (uint64, error)
  • func (s *Store) Lock() (err error)
  • func (s *Store) LockPath() string
  • func (s *Store) OraclePath() string
  • func (s *Store) TimestampPath() string
  • func (s *Store) Unlock() error
  • func (s *Store) UpdateGroup(g *Group) error
  • func (s *Store) UpdateOracle(o *Oracle) error
  • func (s *Store) UpdateTimestamp(ts uint64) error
  • func (s *Store) WithClusterLocked(f func() error) error

Constants

const SpermwhaleDir = "/spermwhale"

Functions

func ClusterDir

func ClusterDir(clusterName string) string

func GroupDir

func GroupDir(clusterName string) string

func GroupPath

func GroupPath(clusterName string, gid int) string

func LockPath

func LockPath(clusterName string) string

func OraclePath

func OraclePath(clusterName string) string

func TimestampPath

func TimestampPath(clusterName string) string

Types

type Cluster

type Cluster struct {
	GroupNumber int `json:"group_number"`
}

type Group

type Group struct {
	Id         int    `json:"id"`
	ServerAddr string `json:"server_addr"`
}

func (*Group) Encode

func (g *Group) Encode() []byte

type Oracle

type Oracle struct {
	ServerAddr string `json:"server_addr"`
}

func (*Oracle) Encode

func (o *Oracle) Encode() []byte

type Store

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

func NewStore

func NewStore(client client.Client, clusterName string) *Store

func (*Store) Acquire

func (s *Store) Acquire() error

func (*Store) Client

func (s *Store) Client() client.Client

func (*Store) Close

func (s *Store) Close() error

func (*Store) DeleteGroup

func (s *Store) DeleteGroup(gid int) error

func (*Store) DeleteTimestamp

func (s *Store) DeleteTimestamp() error

func (*Store) GetLocalIP

func (s *Store) GetLocalIP() (string, error)

func (*Store) GroupDir

func (s *Store) GroupDir() string

func (*Store) GroupPath

func (s *Store) GroupPath(gid int) string

func (*Store) ListGroup

func (s *Store) ListGroup() (map[int]*Group, error)

func (*Store) LoadGroup

func (s *Store) LoadGroup(gid int, must bool) (*Group, error)

func (*Store) LoadOracle

func (s *Store) LoadOracle() (*Oracle, error)

func (*Store) LoadTimestamp

func (s *Store) LoadTimestamp() (uint64, error)

func (*Store) Lock

func (s *Store) Lock() (err error)

func (*Store) LockPath

func (s *Store) LockPath() string

func (*Store) OraclePath

func (s *Store) OraclePath() string

func (*Store) TimestampPath

func (s *Store) TimestampPath() string

func (*Store) Unlock

func (s *Store) Unlock() error

func (*Store) UpdateGroup

func (s *Store) UpdateGroup(g *Group) error

func (*Store) UpdateOracle

func (s *Store) UpdateOracle(o *Oracle) error

func (*Store) UpdateTimestamp

func (s *Store) UpdateTimestamp(ts uint64) error

func (*Store) WithClusterLocked

func (s *Store) WithClusterLocked(f func() error) error