cluster

package
v0.0.0-...-dbfa1ae Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 4, 2019 License: MPL-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// ClusterType is the TypeURL for Cluster discovery responses.
	ClusterType = typePrefix + "Cluster"

	// ListenerType is the TypeURL for Listener discovery responses.
	ListenerType = typePrefix + "Listener"
)

Variables

View Source 
var ConsulBootstrapLimit = 10

ConsulBootstrapLimit is the maximum members to expect in a consul datacenter

View Source 
var DiscoverBootstrapLimit = 10

DiscoverBootstrapLimit is the limit of attempts for the serf agent to try to join a cluster

Functions

func NewRequest 

func NewRequest(key, value int) []byte

func TestJoin 

func TestJoin(t *testing.T, s1 *Server, other ...*Server)

TestJoin joins two servers

func TrackLeader 

func TrackLeader(b backend.SystemView, f func(ctx context.Context))

TrackLeader is a helper function that runs a callback when the node is set as the leadedr

Types

type Config 

type Config struct {
	NodeName    string
	ServiceName string
	DataDir     string

	RPCAddr *net.TCPAddr

	RetryJoin     []string
	AdvertiseAddr *net.IPAddr

	SerfConfig   *serf.Config
	ConsulConfig *consul.Config

	RaftConfig        *raft.Config
	BootstrapExpected int32

	LogOutput io.Writer
	Backend   backend.Backend

	Telemetry *Telemetry
	Envoy     *EnvoyConfig
}

Config for the cluster server

func DefaultConfig 

func DefaultConfig() *Config

DefaultConfig returns a cluster server config with default values

type EnvoyClient 

type EnvoyClient struct {
	IngressPorts []Proxy
	EgressPorts  []Proxy
	// contains filtered or unexported fields
}

EnvoyClient is the control plane for envoy

func NewEnvoyClient 

func NewEnvoyClient(logger hclog.Logger, addr net.IP, config *EnvoyConfig) (*EnvoyClient, error)

NewEnvoyClient creates a new envoy proxy

func (*EnvoyClient) Close 

func (e *EnvoyClient) Close() error

Close stops the envoy proxy

func (*EnvoyClient) DeltaAggregatedResources 

func (e *EnvoyClient) DeltaAggregatedResources(envoydisc.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error

DeltaAggregatedResources implements envoydisc.AggregatedDiscoveryServiceServer

func (*EnvoyClient) EmitStats 

func (e *EnvoyClient) EmitStats(period time.Duration, stopCh <-chan struct{})

EmitStats emits the stats of the envoy proxy

func (*EnvoyClient) IsEnabled 

func (e *EnvoyClient) IsEnabled() bool

IsEnabled returns true if Envoy is enabled.

func (*EnvoyClient) RegisterEgressAddress 

func (e *EnvoyClient) RegisterEgressAddress(name string, addr string, port int)

RegisterEgressAddress registers an egress entry for an address and a port

func (*EnvoyClient) RegisterIngressAddress 

func (e *EnvoyClient) RegisterIngressAddress(name string, port int)

RegisterIngressAddress registers an egress entry for a port. Since we are building a proxy we expect the destiny address to bind to localhost.

func (*EnvoyClient) Resolve 

func (e *EnvoyClient) Resolve(addr *net.TCPAddr) *net.TCPAddr

Resolve resolves a proxy address

func (*EnvoyClient) StreamAggregatedResources 

func (e *EnvoyClient) StreamAggregatedResources(stream envoydisc.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

StreamAggregatedResources implements envoydisc.AggregatedDiscoveryServiceServer

type EnvoyConfig 

type EnvoyConfig struct {
	// Enabled is set to true to enable the envoy proxy
	Enabled bool `hcl:"enabled"`

	// AdminPort is the port for the envoy admin rest-api
	AdminPort int `hcl:"admin_port"`

	// GRPCPort is the port for the grpc control plane
	GRPCPort int `hcl:"grpc_port"`

	// Bianry is the path to the envoy binary
	Binary string `hcl:"binary"`

	// BaseID is used to differentiate different envoy instances on the same machine
	BaseID int `hcl:"base_id"`
}

EnvoyConfig is the envoy configuration

func DefaultEnvoyConfig 

func DefaultEnvoyConfig() *EnvoyConfig

DefaultEnvoyConfig is the default envoy configuration

func (*EnvoyConfig) IsEnabled 

func (e *EnvoyConfig) IsEnabled() bool

IsEnabled returns true if Envoy is enabled.

type Proxy 

type Proxy struct {
	Label string // name of the proxy
	Addr  string // addr for an egress proxy
	Value int    // the port envoy binds
	To    int    // the port the proxy forwards to
}

Proxy is a reference for a proxy in envoy.

type ProxyType 

type ProxyType int

ProxyType is the type of proxy 

const (
	// IngressProxy is an ingress proxy type
	IngressProxy ProxyType = iota

	// EgressProxy is an egress proxy type
	EgressProxy
)

func (ProxyType) String 

func (p ProxyType) String() string

type RPCType 

type RPCType byte

RPCType represents different types of rpc to be used 

const (
	// RPCRaft is the Raft rpc type
	RPCRaft RPCType = 0x02
)

type RaftLayer 

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

RaftLayer implements the raft.StreamLayer to handle the raft connections inside the rpc stream.

func NewRaftLayer 

func NewRaftLayer(addr net.Addr) *RaftLayer

NewRaftLayer creates a new raft layer.

func (*RaftLayer) Accept 

func (l *RaftLayer) Accept() (net.Conn, error)

Accept implements the raft.StreamLayer interface

func (*RaftLayer) Addr 

func (l *RaftLayer) Addr() net.Addr

Addr implements the raft.StreamLayer interface

func (*RaftLayer) Close 

func (l *RaftLayer) Close() error

Close implements the raft.StreamLayer interface

func (*RaftLayer) Dial 

func (l *RaftLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)

Dial implements the raft.StreamLayer interface

func (*RaftLayer) Handoff 

func (l *RaftLayer) Handoff(c net.Conn) error

Handoff implements the raft.StreamLayer interface

type Server 

type Server struct {
	Config *Config

	// Serf
	Serf *serf.Serf

	EventCh chan serf.Event

	// Raft
	Raft        *raft.Raft
	LeaderChAux chan bool

	Agent *consul.Agent

	ReconcileChAux chan serf.Member

	InmemSink *metrics.InmemSink
	// contains filtered or unexported fields
}

Server is a cloud-cluster server which handles a serf, raft and a consul agent instances

func NewServer 

func NewServer(config *Config, logger hclog.Logger) (*Server, error)

NewServer creates a new cloud-cluster server

func TestServer 

func TestServer(t *testing.T) *Server

TestServer creates a test server

func (*Server) IsLeader 

func (s *Server) IsLeader() bool

func (*Server) Join 

func (s *Server) Join(peers []string) (int, error)

func (*Server) Leader 

func (s *Server) Leader() string

func (*Server) LeaderCh 

func (s *Server) LeaderCh() chan bool

func (*Server) Leave 

func (s *Server) Leave() error

func (*Server) Members 

func (s *Server) Members() []serf.Member

func (*Server) Peers 

func (s *Server) Peers() (reply []string)

func (*Server) RPC 

func (s *Server) RPC(method string, args interface{}, reply interface{}) error

RPC makes a call to the local rpc server

func (*Server) RPCRemote 

func (s *Server) RPCRemote(server string, method string, args interface{}, reply interface{}) error

RPCRemote is used to call another peer

func (*Server) ReconcileCh 

func (s *Server) ReconcileCh() chan serf.Member

func (*Server) RegisterRPC 

func (s *Server) RegisterRPC(rcvr interface{})

func (*Server) Resolve 

func (s *Server) Resolve(addr *net.TCPAddr) *net.TCPAddr

func (*Server) Shutdown 

func (s *Server) Shutdown() error

type SetRequest 

type SetRequest struct {
	Key, Value int
}

type SimpleFSM 

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

func (*SimpleFSM) Apply 

func (f *SimpleFSM) Apply(l *raft.Log) interface{}

func (*SimpleFSM) Restore 

func (f *SimpleFSM) Restore(io.ReadCloser) error

func (*SimpleFSM) Snapshot 

func (f *SimpleFSM) Snapshot() (raft.FSMSnapshot, error)

func (*SimpleFSM) State 

func (f *SimpleFSM) State() *State

type State 

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

func (*State) Set 

func (s *State) Set(key, value int)

type Status 

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

Status is the endpoint to query for the status of the server

func (*Status) Leader 

func (s *Status) Leader(args interface{}, reply *string) error

Leader returns the current leader of the cluster

func (*Status) Peers 

func (s *Status) Peers(args interface{}, reply *[]string) error

Peers returns the list of servers of the raft cluster

func (*Status) Ping 

func (s *Status) Ping(args struct{}, reply *struct{}) error

Ping checks for connectivity

type Telemetry 

type Telemetry struct {
	// DataDogAddr is the address of the statds-datadog extension server
	DataDogAddr string `hcl:"datadog_address"`
}

Telemetry is the telemetry config

Source Files

View all Source files

Directories

Path Synopsis
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.