broker

Documentation

Index

• type DialFunc
• type T
  • func New(fd fsdir.T, cfg *clientcfg.C, l *log.Logger) *T
  • func (t *T) Activate() (err error)
  • func (t *T) ActiveCircuit() (r circuit.T)
  • func (t *T) Circuit() (r []*relayentry.T, err error)
  • func (t *T) Config() *clientcfg.C
  • func (t *T) ContractInfo() *contractinfo.T
  • func (t *T) CurrentPofs() []*pof.T
  • func (t *T) CurrentSK() *servicekey.T
  • func (t *T) GetSK(fetch bool) (*servicekey.T, error)
  • func (t *T) Import(u url.URL) (ak *accesskey.T, err error)
  • func (t *T) IsUpgradeable() (r bool)
  • func (t *T) NewSKFromPof(skurl string, p *pof.T) (*servicekey.T, error)
  • func (t *T) RefreshSK() (err error)
  • func (t *T) Relays() (rs relaylist.T, err error)
  • func (t *T) Reload()
  • func (t *T) SaveConfig() error
  • func (t *T) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (t *T) SetUpgradeable(val bool)
  • func (t *T) Shutdown()
  • func (t *T) Sync() (err error)
  • func (t *T) WriteBypass() (err error)

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

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