cluster

package

v0.0.0-...-0c4a898 Latest Latest Go to latest Published: Dec 13, 2014 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

View Source

const DefaultClusterPort = 8476

View Source

const DefaultPath = "/var/lib/vega"

View Source

var DefaultRoutingPrefix = "mailbox-routing"

func NewClusterNode(path string, router *vega.Router) (*clusterNode, error)

func NewConsulClient(token string) *consulapi.Client

func NewConsulRoutingTable(prefix, id string, client *consulapi.Client) (*consulRoutingTable, error)

func NewMemClusterNode(path string) (*clusterNode, error)

type ConsulClusterNode struct {
	Config *ConsulNodeConfig
	// contains filtered or unexported fields
}

func NewConsulClusterNode(config *ConsulNodeConfig) (*ConsulClusterNode, error)

func (cn ConsulClusterNode) Abandon(name string) error

func (cn *ConsulClusterNode) Accept() error

func (cn ConsulClusterNode) AddRoute(name string, s vega.Storage)

func (cn *ConsulClusterNode) Cleanup() error

func (cn *ConsulClusterNode) Close() error

func (cn ConsulClusterNode) Declare(name string) error

func (cn ConsulClusterNode) LongPoll(name string, til time.Duration) (*vega.Delivery, error)

func (cn ConsulClusterNode) LongPollCancelable(name string, til time.Duration, done chan struct{}) (*vega.Delivery, error)

func (cn ConsulClusterNode) Poll(name string) (*vega.Delivery, error)

func (cn ConsulClusterNode) Push(name string, msg *vega.Message) error

func (cn ConsulClusterNode) Registry() *vega.Registry

type ConsulNodeConfig struct {
	AdvertiseAddr string
	ListenPort    int
	DataPath      string
	ConsulToken   string
	RoutingPrefix string
}

func (cn *ConsulNodeConfig) AdvertiseID() string

func (cn *ConsulNodeConfig) ListenAddr() string

func (cn *ConsulNodeConfig) Normalize() error