netAgent

package module

v0.0.0-...-29a4dac Latest Latest Go to latest Published: Jun 14, 2015 License: Apache-2.0 Imports: 21 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/WIZARD-CXY/netAgent

Links

Open Source Insights

README ¶

Deprecated!. Move to cxy-sdn for univeral management now

netAgent

Embedded network agent for using consul to communicate and do failure detection and store net config. Bring the consul major functionality into this one binary without installing consul binary onto the nodes

Documentation ¶

Index ¶

Constants
Variables
func Delete(store string, key string) int
func Execute(args ...string) int
func Get(store string, key string) ([]byte, int, bool)
func GetAll(store string) ([][]byte, []int, bool)
func Join(addr string) error
func Leave() error
func Put(store string, key string, value []byte, oldVal []byte) int
func RegisterForKeyUpdates(store string, key string, listener Listener)
func RegisterForNodeUpdates(listener Listener)
func RegisterForStoreUpdates(store string, listener Listener)
func StartAgent(serverMode bool, bootstrap bool, bindInterface string, dataDir string) error
type KVRespBody
type Listener
type Node
type NotifyUpdateType
type WatchType

Constants ¶

View Source

const (
	OK = iota
	OUTDATED
	ERROR
)

View Source

const (
	NOTIFY_UPDATE_ADD = iota
	NOTIFY_UPDATE_MODIFY
	NOTIFY_UPDATE_DELETE
)

View Source

const (
	WATCH_TYPE_NODE = iota
	WATCH_TYPE_KEY
	WATCH_TYPE_STORE
	WATCH_TYPE_EVENT
)

View Source

const CONSUL_CATALOG_BASE_URL = "http://localhost:8500/v1/catalog/"

View Source

const CONSUL_KV_BASE_URL = "http://localhost:8500/v1/kv/"

View Source

const Version = "0.5.2"

the consul version use here

View Source

const VersionPrerelease = "dev"

Variables ¶

View Source

var Commands map[string]cli.CommandFactory

Commands is the mapping of all the available Consul commands.

View Source

var GitCommit string

View Source

var GitDescribe string

Functions ¶

func Delete ¶

func Delete(store string, key string) int

return val indicate the error type

func Execute ¶

func Execute(args ...string) int

Execute function is borrowed from Consul's main.go

func Get ¶

func Get(store string, key string) ([]byte, int, bool)

1st return value as []byte 2nd return its ModifyIndex 3rd return ok or not

func GetAll ¶

func GetAll(store string) ([][]byte, []int, bool)

get all key-value pairs in one store from backend

func Join ¶

func Join(addr string) error

func Leave ¶

func Leave() error

func Put ¶

func Put(store string, key string, value []byte, oldVal []byte) int

return val indicate the error type need old val as 4-th param

func RegisterForKeyUpdates ¶

func RegisterForKeyUpdates(store string, key string, listener Listener)

func RegisterForNodeUpdates ¶

func RegisterForNodeUpdates(listener Listener)

func RegisterForStoreUpdates ¶

func RegisterForStoreUpdates(store string, listener Listener)

func StartAgent ¶

func StartAgent(serverMode bool, bootstrap bool, bindInterface string, dataDir string) error

Types ¶

type KVRespBody ¶

type KVRespBody struct {
	CreateIndex int    `json:"CreateIndex,omitempty"`
	ModifyIndex int    `json:"ModifyIndex,omitempty"`
	Key         string `json:"Key,omitempty"`
	Flags       int    `json:Flags,omitempty"`
	Value       string `json:Value,omitempty"`
}

type Listener ¶

type Listener interface {
	NotifyNodeUpdate(NotifyUpdateType, string)
	NotifyKeyUpdate(NotifyUpdateType, string, []byte)
	NotifyStoreUpdate(NotifyUpdateType, string, map[string][]byte)
}

type Node ¶

type Node struct {
	Name    string `json:"Name,omitempty"`
	Address string `json:"Addr,ommitempty"`
}

type NotifyUpdateType ¶

type NotifyUpdateType int

type WatchType ¶

type WatchType int

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
Godeps
_workspace/src/github.com/armon/circbuf
_workspace/src/github.com/armon/go-metrics
_workspace/src/github.com/armon/go-metrics/prometheus +build go1.3	+build go1.3
_workspace/src/github.com/armon/go-radix
_workspace/src/github.com/armon/gomdb
_workspace/src/github.com/boltdb/bolt Package bolt implements a low-level key/value store in pure Go.	Package bolt implements a low-level key/value store in pure Go.
_workspace/src/github.com/boltdb/bolt/cmd/bolt
_workspace/src/github.com/golang/glog Package glog implements logging analogous to the Google-internal C++ INFO/ERROR/V setup.	Package glog implements logging analogous to the Google-internal C++ INFO/ERROR/V setup.
_workspace/src/github.com/hashicorp/consul-migrate/migrator
_workspace/src/github.com/hashicorp/consul/acl
_workspace/src/github.com/hashicorp/consul/api
_workspace/src/github.com/hashicorp/consul/command
_workspace/src/github.com/hashicorp/consul/command/agent
_workspace/src/github.com/hashicorp/consul/consul
_workspace/src/github.com/hashicorp/consul/consul/structs
_workspace/src/github.com/hashicorp/consul/tlsutil
_workspace/src/github.com/hashicorp/consul/watch
_workspace/src/github.com/hashicorp/go-checkpoint checkpoint is a package for checking version information and alerts for a HashiCorp product.	checkpoint is a package for checking version information and alerts for a HashiCorp product.
_workspace/src/github.com/hashicorp/go-msgpack/codec High Performance, Feature-Rich Idiomatic Go encoding library for msgpack and binc .	High Performance, Feature-Rich Idiomatic Go encoding library for msgpack and binc .
_workspace/src/github.com/hashicorp/go-multierror
_workspace/src/github.com/hashicorp/go-syslog
_workspace/src/github.com/hashicorp/golang-lru This package provides a simple LRU cache.	This package provides a simple LRU cache.
_workspace/src/github.com/hashicorp/hcl hcl is a package for decoding HCL into usable Go structures.	hcl is a package for decoding HCL into usable Go structures.
_workspace/src/github.com/hashicorp/hcl/hcl
_workspace/src/github.com/hashicorp/hcl/json
_workspace/src/github.com/hashicorp/logutils Package logutils augments the standard log package with levels.	Package logutils augments the standard log package with levels.
_workspace/src/github.com/hashicorp/memberlist memberlist is a library that manages cluster membership and member failure detection using a gossip based protocol.	memberlist is a library that manages cluster membership and member failure detection using a gossip based protocol.
_workspace/src/github.com/hashicorp/net-rpc-msgpackrpc Package msgpackrpc implements a MessagePack-RPC ClientCodec and ServerCodec for the rpc package, using the same API as the Go standard library for jsonrpc.	Package msgpackrpc implements a MessagePack-RPC ClientCodec and ServerCodec for the rpc package, using the same API as the Go standard library for jsonrpc.
_workspace/src/github.com/hashicorp/raft
_workspace/src/github.com/hashicorp/raft-boltdb
_workspace/src/github.com/hashicorp/raft-mdb
_workspace/src/github.com/hashicorp/raft/bench
_workspace/src/github.com/hashicorp/scada-client
_workspace/src/github.com/hashicorp/serf/serf
_workspace/src/github.com/hashicorp/yamux
_workspace/src/github.com/inconshreveable/muxado muxado is an implementation of a general-purpose stream-multiplexing protocol.	muxado is an implementation of a general-purpose stream-multiplexing protocol.
_workspace/src/github.com/inconshreveable/muxado/proto
_workspace/src/github.com/inconshreveable/muxado/proto/buffer
_workspace/src/github.com/inconshreveable/muxado/proto/ext
_workspace/src/github.com/inconshreveable/muxado/proto/frame
_workspace/src/github.com/miekg/dns Package dns implements a full featured interface to the Domain Name System.	Package dns implements a full featured interface to the Domain Name System.
_workspace/src/github.com/miekg/dns/idn Package idn implements encoding from and to punycode as speficied by RFC 3492.	Package idn implements encoding from and to punycode as speficied by RFC 3492.
_workspace/src/github.com/mitchellh/cli
_workspace/src/github.com/mitchellh/mapstructure The mapstructure package exposes functionality to convert an abitrary map[string]interface{} into a native Go structure.	The mapstructure package exposes functionality to convert an abitrary map[string]interface{} into a native Go structure.
_workspace/src/github.com/ryanuber/columnize
_workspace/src/golang.org/x/crypto/ssh/terminal Package terminal provides support functions for dealing with terminals, as commonly found on UNIX systems.	Package terminal provides support functions for dealing with terminals, as commonly found on UNIX systems.
main

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL