master

Documentation

Index

• Variables
• type JoinParam
• type Master
  • func New(addr string) *Master
  • func (m *Master) JoinNode(args *JoinParam, reply *PeerParam) error
  • func (m *Master) Peers() ([]string, error)
  • func (m *Master) Start()
• type PeerParam

Variables

var Default = New(defaultAddr)

Default returns a new Master with the default addr

Types

type JoinParam

type JoinParam struct {
	HTTPAddr string `json:"httpAddr"`
	NodeAddr string `json:"nodeAddr"`
}

type Master

type Master struct {
	// runtime data
	sync.RWMutex
	// contains filtered or unexported fields
}

Master for a group of caching nodes

func New

func New(addr string) *Master

New returns a new Master with the addr

func (*Master) JoinNode

func (m *Master) JoinNode(args *JoinParam, reply *PeerParam) error

func (*Master) Peers

func (m *Master) Peers() ([]string, error)

Peers returns the httpAddrs

func (*Master) Start

func (m *Master) Start()

Start starts the master listening on addr

type PeerParam

type PeerParam struct {
	Peers []string `json:"peers"`
	DBs   []string `json:"dbs"`
}