ecc

README

ecc

Embedded Clustering Client. Currently using Consul.

Documentation

Index

• Constants
• Variables
• func ConsulGet(url string) (string, bool)
• func Delete(store string, key string) eccerror
• func Execute(args ...string) int
• func Get(store string, key string) ([]byte, int, bool)
• func GetAll(store string) ([][]byte, []int, bool)
• func HasStarted() bool
• func Join(address string) error
• func Leave() error
• func Put(store string, key string, value []byte, oldValue []byte) eccerror
• func RegisterForKeyUpdates(store string, key string, listener Listener)
• func RegisterForNodeUpdates(listener Listener)
• func RegisterForStoreUpdates(store string, listener Listener)
• func Start(serverMode bool, bootstrap bool, bindInterface string, dataDir string) error
• type Listener
• type NotifyUpdateType
• type Store
• type WatchType

Constants

const (
	OK = iota
	OUTDATED
	ERROR
)

const (
	NOTIFY_UPDATE_ADD = iota
	NOTIFY_UPDATE_MODIFY
	NOTIFY_UPDATE_DELETE
)

const (
	WATCH_TYPE_NODE = iota
	WATCH_TYPE_KEY
	WATCH_TYPE_STORE
	WATCH_TYPE_EVENT
)

const CONSUL_BASE_URL = "http://localhost:8500/v1/"

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

const Version = "0.4.1"

The main version number that is being run at the moment.

const VersionPrerelease = ""

A pre-release marker for the version. If this is "" (empty string) then it means that it is a final release. Otherwise, this is a pre-release such as "dev" (in development), "beta", "rc1", etc.

Variables

var Commands map[string]cli.CommandFactory

Commands is the mapping of all the available Consul commands.

var GitCommit string

The git commit that was compiled. This will be filled in by the compiler.

var GitDescribe string

var OfflineSupport bool = true

Functions

func ConsulGet

func ConsulGet(url string) (string, bool)

func Delete

func Delete(store string, key string) eccerror

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)

func GetAll

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

func HasStarted

func HasStarted() bool

func Join

func Join(address string) error

func Leave

func Leave() error

func Put

func Put(store string, key string, value []byte, oldValue []byte) eccerror

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 Start

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

Types

type Listener

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

type NotifyUpdateType

type NotifyUpdateType int

type Store

type Store struct {
	// contains filtered or unexported fields
}

type WatchType

type WatchType int