api

Feb 16, 2021

Changes in this version

type NestNode

+ StartTime time.Time

type NestService

+ StartTime time.Time

Feb 15, 2021

Changes in this version

type NestNode

+ Progress *NestProgress

+ type NestProgress struct

+ Current int32

+ InProgress bool

+ Total int32

type NestService

+ Progress *NestProgress

+ type Progress func(int32, int32)

Feb 14, 2021

Changes in this version

+ type Client interface

+ Hash func(url, key string) (string, error)

+ HashRing func(url, key string) (string, error)

+ Robin func(url string) (string, error)

+ Round func(url string) (string, error)

+ Services func(serviceName string, state StateType) Service

+ func RiffClient(url string) (Client, error)

+ type HashKey uint32

+ type HashKeyOrder []HashKey

+ func (h HashKeyOrder) Len() int

+ func (h HashKeyOrder) Less(i, j int) bool

+ func (h HashKeyOrder) Swap(i, j int)

+ type HashRing struct

+ func New(nodes []string) *HashRing

+ func NewWithWeights(weights map[string]int) *HashRing

+ func (h *HashRing) AddNode(node string) *HashRing

+ func (h *HashRing) AddWeightedNode(node string, weight int) *HashRing

+ func (h *HashRing) GenKey(key string) HashKey

+ func (h *HashRing) GetNode(stringKey string) (node string, ok bool)

+ func (h *HashRing) GetNodePos(stringKey string) (pos int, ok bool)

+ func (h *HashRing) GetNodes(stringKey string, size int) (nodes []string, ok bool)

+ func (h *HashRing) RemoveNode(node string) *HashRing

+ func (h *HashRing) Size() int

+ func (h *HashRing) UpdateWeightedNode(node string, weight int) *HashRing

+ func (h *HashRing) UpdateWithWeights(weights map[string]int)

+ type HttpClient struct

+ type RpcClient struct

+ func (this *RpcClient) Hash(url, key string) (string, error)

+ func (this *RpcClient) HashRing(url, key string) (string, error)

+ func (this *RpcClient) Robin(url string) (string, error)

+ func (this *RpcClient) Round(url string) (string, error)

+ func (this *RpcClient) Services(name string, state StateType) (service Service)

Jan 11, 2019

Changes in this version

type NestNode

+ StatusContent string

type NestService

+ IP string

+ StatusContent string

type Node

+ HttpPort int

+ RpcPort int

Oct 10, 2018

Changes in this version

type CmdType

+ func CmdType_FromName(name string) CmdType

+ func (c CmdType) Name() string

+ func (c CmdType) Value() int

type StateType

+ func StateType_FromName(name string) StateType

+ func (s StateType) Name() string

+ func (s StateType) Value() int

Feb 11, 2018

Changes in this version

+ func NewClient(address string) (*rpc.Client, error)

+ func NewJsonClient(address string) (*rpc.Client, error)

+ func NewJsonClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec

+ func NewJsonServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec

+ type RPCType byte

+ const RPCGob

+ const RPCJson

Feb 7, 2018

Changes in this version

+ func NewGobClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec

+ func NewGobServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec

+ func TimeoutCoder(f func(interface{}) error, e interface{}, msg string) error

+ type CmdType int

+ const CmdRestart

+ const CmdStart

+ const CmdStop

+ func (c CmdType) String() string

+ type NestNode struct

+ Config string

+ DataCenter string

+ IP string

+ IsSelf bool

+ Name string

+ Port int

+ RpcPort int

+ SnapShot string

+ State StateType

+ Version int

+ type NestNodes []*NestNode

+ type NestService struct

+ Config string

+ Name string

+ Port int

+ State StateType

+ type NestServices []*NestService

+ type Node struct

+ DataCenter string

+ IP string

+ IsSelf bool

+ Name string

+ Port int

+ SnapShot string

+ State StateType

+ Version int

+ type Nodes []*Node

+ type ParamNode struct

+ Name string

+ type ParamService struct

+ Name string

+ State StateType

+ type ParamServiceMutation struct

+ Cmd CmdType

+ Name string

+ type Service struct

+ Name string

+ type Services []*Service

+ type StateType int

+ const StateAlive

+ const StateAll

+ const StateDead

+ const StateSuspect

+ func (s StateType) String() string