cluster

Documentation

Index

• func Deregister(node *Node) error
• func Init(service string)
• func Register(node *Node, ttl int) error
• func WatchClusterConfig() error
• type Config
  • func GetClusterConfig() Config
• type Node
  • func Discover() (output []*Node, err error)

Functions

func Deregister

func Deregister(node *Node) error

func Init

func Init(service string)

func Register

func Register(node *Node, ttl int) error

func WatchClusterConfig

func WatchClusterConfig() error

Types

type Config

type Config struct {
	LogLevel  string `json:"logLevel"`
	RateLimit struct {
		Middle int `json:"middle"`
		Low    int `json:"low"`
	} `json:"rateLimit"`
	CircuitBreaker struct {
		Cpu     int `json:"cpu"`
		Latency int `json:"latency"`
	} `json:"circuitBreaker"`
}

func GetClusterConfig

func GetClusterConfig() Config

type Node

type Node struct {
	Addr    string `json:"addr"`
	Version string `json:"version"`
	Proto   string `json:"proto"`
}

func Discover

func Discover() (output []*Node, err error)