node

Documentation

Index

• Variables
• type Node
  • func New(httpAddr string, nodeAddr string, masterAddr string) *Node
  • func (node *Node) Start()

Variables

var (
	// ErrDataNotFound for not found data error
	ErrDataNotFound = fmt.Errorf("%s data not found", logPrefix)
	// ErrDatabaseQueryTimeout for underlying data query timeout error
	ErrDatabaseQueryTimeout = fmt.Errorf("%s upderlying data query timeout", logPrefix)
)

Types

type Node

type Node struct {
	// meta
	sync.RWMutex // protect updating for dbs and peers

	// node http server
	*gin.Engine
	// contains filtered or unexported fields
}

Node for one groupcache server

func New

func New(httpAddr string, nodeAddr string, masterAddr string) *Node

New returns a new Node with the given info

func (*Node) Start

func (node *Node) Start()

Start starts the server