chain

Documentation

Index

• Variables
• func NewEnvDialer(dialer bridge.Dialer) bridge.Dialer
• func NewShuntDialer(dialer bridge.Dialer, matchDialer bridge.Dialer, matcher hostmatcher.Matcher) bridge.Dialer
• func ShowChain(dials, listens []string) string
• func ShowChainWithConfig(config config.Chain) string
• type Bridge
  • func NewBridge(logger logr.Logger, dump bool) *Bridge
  • func (b *Bridge) Bridge(ctx context.Context, listens, dials []string) error
  • func (b *Bridge) BridgeWithConfig(ctx context.Context, config config.Chain) error
• type BridgeChain
  • func NewBridgeChain() *BridgeChain
  • func (b *BridgeChain) BridgeChain(dialer bridge.Dialer, addresses ...string) (bridge.Dialer, error)
  • func (b *BridgeChain) BridgeChainWithConfig(dialer bridge.Dialer, addresses ...config.Node) (bridge.Dialer, error)
  • func (b *BridgeChain) Dial(dialer bridge.Dialer, addresses []string, probeUrl string) (bridge.Dialer, error)
  • func (b *BridgeChain) Register(name string, bridger bridge.Bridger) error
  • func (b *BridgeChain) RegisterDefault(bridger bridge.Bridger)

Variables

var (
	NoProxy   hostmatcher.Matcher
	OnlyProxy hostmatcher.Matcher
)

var Default = NewBridgeChain()

Functions

func NewEnvDialer

func NewEnvDialer(dialer bridge.Dialer) bridge.Dialer

func NewShuntDialer

func NewShuntDialer(dialer bridge.Dialer, matchDialer bridge.Dialer, matcher hostmatcher.Matcher) bridge.Dialer

func ShowChain

func ShowChain(dials, listens []string) string

func ShowChainWithConfig

func ShowChainWithConfig(config config.Chain) string

Types

type Bridge

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

func NewBridge

func NewBridge(logger logr.Logger, dump bool) *Bridge

func (*Bridge) Bridge

func (b *Bridge) Bridge(ctx context.Context, listens, dials []string) error

func (*Bridge) BridgeWithConfig

func (b *Bridge) BridgeWithConfig(ctx context.Context, config config.Chain) error

type BridgeChain

type BridgeChain struct {
	DialerFunc func(dialer bridge.Dialer) bridge.Dialer
	// contains filtered or unexported fields
}

BridgeChain is a bridger that supports multiple crossing of bridger.

func NewBridgeChain

func NewBridgeChain() *BridgeChain

NewBridgeChain create a new BridgeChain.

func (*BridgeChain) BridgeChain

func (b *BridgeChain) BridgeChain(dialer bridge.Dialer, addresses ...string) (bridge.Dialer, error)

BridgeChain is multiple crossing of bridge.

func (*BridgeChain) BridgeChainWithConfig

func (b *BridgeChain) BridgeChainWithConfig(dialer bridge.Dialer, addresses ...config.Node) (bridge.Dialer, error)

BridgeChainWithConfig is multiple crossing of bridge.

func (*BridgeChain) Dial

func (b *BridgeChain) Dial(dialer bridge.Dialer, addresses []string, probeUrl string) (bridge.Dialer, error)

func (*BridgeChain) Register

func (b *BridgeChain) Register(name string, bridger bridge.Bridger) error

Register is register a new bridger for BridgeChain.

func (*BridgeChain) RegisterDefault

func (b *BridgeChain) RegisterDefault(bridger bridge.Bridger)

RegisterDefault is register a default bridger for BridgeChain.