Versions in this module Expand all Collapse all v1 v1.0.1 Jun 26, 2022 Changes in this version + var Control_State_name = map[int32]string + var Control_State_value = map[string]int32 + var File_app_reverse_config_proto protoreflect.FileDescriptor + type Bridge struct + func NewBridge(config *BridgeConfig, dispatcher routing.Dispatcher) (*Bridge, error) + func (b *Bridge) Close() error + func (b *Bridge) Start() error + type BridgeConfig struct + Domain string + Tag string + func (*BridgeConfig) Descriptor() ([]byte, []int) + func (*BridgeConfig) ProtoMessage() + func (x *BridgeConfig) GetDomain() string + func (x *BridgeConfig) GetTag() string + func (x *BridgeConfig) ProtoReflect() protoreflect.Message + func (x *BridgeConfig) Reset() + func (x *BridgeConfig) String() string + type BridgeWorker struct + func NewBridgeWorker(domain string, tag string, d routing.Dispatcher) (*BridgeWorker, error) + func (w *BridgeWorker) Close() error + func (w *BridgeWorker) Connections() uint32 + func (w *BridgeWorker) Dispatch(ctx context.Context, dest net.Destination) (*transport.Link, error) + func (w *BridgeWorker) DispatchLink(ctx context.Context, dest net.Destination, link *transport.Link) error + func (w *BridgeWorker) IsActive() bool + func (w *BridgeWorker) Start() error + func (w *BridgeWorker) Type() interface{} + type Config struct + BridgeConfig []*BridgeConfig + PortalConfig []*PortalConfig + func (*Config) Descriptor() ([]byte, []int) + func (*Config) ProtoMessage() + func (x *Config) GetBridgeConfig() []*BridgeConfig + func (x *Config) GetPortalConfig() []*PortalConfig + func (x *Config) ProtoReflect() protoreflect.Message + func (x *Config) Reset() + func (x *Config) String() string + type Control struct + Random []byte + State Control_State + func (*Control) Descriptor() ([]byte, []int) + func (*Control) ProtoMessage() + func (c *Control) FillInRandom() + func (x *Control) GetRandom() []byte + func (x *Control) GetState() Control_State + func (x *Control) ProtoReflect() protoreflect.Message + func (x *Control) Reset() + func (x *Control) String() string + type Control_State int32 + const Control_ACTIVE + const Control_DRAIN + func (Control_State) Descriptor() protoreflect.EnumDescriptor + func (Control_State) EnumDescriptor() ([]byte, []int) + func (Control_State) Type() protoreflect.EnumType + func (x Control_State) Enum() *Control_State + func (x Control_State) Number() protoreflect.EnumNumber + func (x Control_State) String() string + type Outbound struct + func (o *Outbound) Close() error + func (o *Outbound) Dispatch(ctx context.Context, link *transport.Link) + func (o *Outbound) Start() error + func (o *Outbound) Tag() string + type Portal struct + func NewPortal(config *PortalConfig, ohm outbound.Manager) (*Portal, error) + func (p *Portal) Close() error + func (p *Portal) HandleConnection(ctx context.Context, link *transport.Link) error + func (p *Portal) Start() error + type PortalConfig struct + Domain string + Tag string + func (*PortalConfig) Descriptor() ([]byte, []int) + func (*PortalConfig) ProtoMessage() + func (x *PortalConfig) GetDomain() string + func (x *PortalConfig) GetTag() string + func (x *PortalConfig) ProtoReflect() protoreflect.Message + func (x *PortalConfig) Reset() + func (x *PortalConfig) String() string + type PortalWorker struct + func NewPortalWorker(client *mux.ClientWorker) (*PortalWorker, error) + func (w *PortalWorker) Closed() bool + func (w *PortalWorker) IsFull() bool + type Reverse struct + func (r *Reverse) Close() error + func (r *Reverse) Init(config *Config, d routing.Dispatcher, ohm outbound.Manager) error + func (r *Reverse) Start() error + func (r *Reverse) Type() interface{} + type StaticMuxPicker struct + func NewStaticMuxPicker() (*StaticMuxPicker, error) + func (p *StaticMuxPicker) AddWorker(worker *PortalWorker) + func (p *StaticMuxPicker) PickAvailable() (*mux.ClientWorker, error)
Go to main page