privacy

Apr 19, 2021

Changes in this version

type Client

+ func (c *Client) UpCheck() (bool, error)

+ type ClientOption func(client *Client) error

Jul 10, 2020

Changes in this version

+ const UnixScheme

+ var ErrPtmAPIFailed = errors.New("ptm api failed")

+ var ErrPtmClientNull = errors.New("ptm client null")

+ var ErrPtmNodeNotRunning = errors.New("ptm node not running")

+ type Client struct

+ func NewClient(ptmNode string) *Client

+ func (c *Client) ReceivePayload(key []byte) ([]byte, error)

+ func (c *Client) SendPayload(pl []byte, b64From string, b64To []string) ([]byte, error)

+ func (c *Client) Upcheck() (bool, error)

+ type Controller struct

+ func NewController(cc *context.ChainContext) *Controller

+ func (c *Controller) Init() error

+ func (c *Controller) Start() error

+ func (c *Controller) Stop() error

+ type HttpTransport struct

+ func (t *HttpTransport) RoundTrip(req *http.Request) (*http.Response, error)

+ func (t *HttpTransport) SetFakeMode(mode bool)

+ type PTM struct

+ func NewPTM(cfg *config.Config) *PTM

+ func (m *PTM) GetDebugInfo() map[string]interface{}

+ func (m *PTM) Init() error

+ func (m *PTM) Receive(data []byte) ([]byte, error)

+ func (m *PTM) Send(data []byte, from string, to []string) (out []byte, err error)

+ func (m *PTM) SetFakeMode(mode bool)

+ func (m *PTM) Start() error

+ func (m *PTM) Stop() error

+ type Transport interface

+ SetFakeMode func(mode bool)

+ type UnixTransport struct

+ DialTimeout time.Duration

+ RequestTimeout time.Duration

+ ResponseHeaderTimeout time.Duration

+ func (t *UnixTransport) RegisterLocation(loc string, path string)

+ func (t *UnixTransport) RoundTrip(req *http.Request) (*http.Response, error)

+ func (t *UnixTransport) SetFakeMode(mode bool)