broker

package
v0.6.2 Latest Latest
Warning

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

Go to latest
Published: Sep 12, 2022 License: MIT Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DialFunc

type DialFunc func(string, string) (net.Conn, error)

type T

type T struct {
	Fd fsdir.T

	// transport
	*transport.T
	// contains filtered or unexported fields
}

func New

func New(fd fsdir.T, cfg *clientcfg.C, l *log.Logger) *T

func (*T) Activate

func (t *T) Activate() (err error)

func (*T) ActiveCircuit

func (t *T) ActiveCircuit() (r circuit.T)

func (*T) Circuit

func (t *T) Circuit() (r []*relayentry.T, err error)

func (*T) Config

func (t *T) Config() *clientcfg.C

func (*T) ContractInfo

func (t *T) ContractInfo() *contractinfo.T

func (*T) CurrentPofs

func (t *T) CurrentPofs() []*pof.T

func (*T) CurrentSK

func (t *T) CurrentSK() *servicekey.T

func (*T) GetSK

func (t *T) GetSK(fetch bool) (*servicekey.T, error)

func (*T) Import

func (t *T) Import(u url.URL) (ak *accesskey.T, err error)

func (*T) IsUpgradeable

func (t *T) IsUpgradeable() (r bool)

func (*T) NewSKFromPof

func (t *T) NewSKFromPof(skurl string, p *pof.T) (*servicekey.T, error)

func (*T) RefreshSK

func (t *T) RefreshSK() (err error)

It is best to lock mutex at the calling site while using this function.

func (*T) Relays

func (t *T) Relays() (rs relaylist.T, err error)

func (*T) Reload

func (t *T) Reload()

func (*T) SaveConfig

func (t *T) SaveConfig() error

func (*T) ServeHTTP

func (t *T) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*T) SetUpgradeable

func (t *T) SetUpgradeable(val bool)

func (*T) Shutdown

func (t *T) Shutdown()

func (*T) Sync

func (t *T) Sync() (err error)

func (*T) WriteBypass added in v0.6.1

func (t *T) WriteBypass() (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL