substrate

Documentation

Index

• Constants
• Variables
• func New(ctx context.Context, node peer.Node, ops ...Option) (client substrate.ProxyClient, err error)
• type Client
  • func (c *Client) Close() error
  • func (c *Client) Peers(pids ...peerCore.ID) *Client
  • func (c *Client) ProxyHTTP(host, path, method string, ops ...client.Option[client.Request]) (<-chan *client.Response, error)
• type Option
  • func CallBack(callback func() Parameters) Option
  • func Threshold(threshold int) Option
  • func Timeout(timeout time.Duration) Option
• type Parameters

Constants

const (
	CommandHTTP = "proxy-http"

	BodyHost   = "host"
	BodyPath   = "path"
	BodyMethod = "method"
)

Variables

var (
	DefaultTimeOut   = 10 * time.Millisecond
	DefaultThreshold = 3
)

Functions

func New

func New(ctx context.Context, node peer.Node, ops ...Option) (client substrate.ProxyClient, err error)

Types

type Client

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

func (*Client) Close

func (c *Client) Close() error

func (*Client) Peers

func (c *Client) Peers(pids ...peerCore.ID) *Client

func (*Client) ProxyHTTP

func (c *Client) ProxyHTTP(host, path, method string, ops ...client.Option[client.Request]) (<-chan *client.Response, error)

type Option

type Option func(c *Client) error

func CallBack

func CallBack(callback func() Parameters) Option

func Threshold

func Threshold(threshold int) Option

func Timeout

func Timeout(timeout time.Duration) Option

type Parameters

type Parameters struct {
	Threshold int
	Timeout   time.Duration
}