proxy

Documentation

Index

• Constants
• Variables
• func ConfigKey() string
• func DiscoveryURI()
• func Follow()
• func Listen(meta *Info) error
• type Info
  • func (i *Info) Listen()
• type ProxyFunc

Constants

const (
	DiscoveryPath = "/docker/ambd/nodes"
)

Variables

var (
	ErrProxyExist = errors.New("proxy exist")

	ErrMissingName = errors.New("proxy name empty")

	Targets []string

	Cancel      ctx.CancelFunc
	RootContext ctx.Context

	Store *libkv.Store
)

var (
	ProxyConfigKey string = "__nobody__"

	ConfigReset ctx.CancelFunc
)

var (
	EnableDiscoveryProxy bool

	DiscoveryProxyInfo = &Info{
		Name: "discovery",
		Net:  "tcp4",
		From: ":2379",
	}
)

Functions

func ConfigKey

func ConfigKey() string

func DiscoveryURI

func DiscoveryURI()

func Follow

func Follow()

func Listen

func Listen(meta *Info) error

Types

type Info

type Info struct {
	// describe what TLS role this instnace is running
	// Either *leave empty*, which is not engage in TLS
	// or *client*, which is to connect with provided certificate
	// or *server*, which is to listen with provided certificate
	ServerRole string `json:"tlsrole"`

	// certificate root path
	CA string `json:"tlscacert"`

	// certificate public private key pair
	Cert string `json:"tlscert"`
	Key  string `json:"tlskey"`

	Name string `json:"name"`

	Net       string   `json:"net"`
	From      string   `json:"src"`
	FromRange []string `json:"range"`

	// static assignment
	To []string `json:"dst,omitempty"`

	// read from discovery
	Service string `json:"srv,omitempty"`

	// Abort proxy handler
	Cancel ctx.CancelFunc `json:"-"`
}

func (*Info) Listen

func (i *Info) Listen()

type ProxyFunc

type ProxyFunc func(ctx.Context, *proxy.ConnOptions) error