client

Documentation

Index

• type Client
  • func New(cfg Config) (*Client, error)
• type Config
• type ProxyPool
  • func NewProxyPool(c *Client) ProxyPool
• type ValidateStreamResponse
• type Validator
  • func NewValidator(c *Client) Validator

Types

type Client

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

func New

func New(cfg Config) (*Client, error)

type Config

type Config struct {
	Endpoint string

	Insecure bool

	// DialTimeout is the timeout for failing to establish a connection.
	DialTimeout time.Duration

	// Context is the default client context; it can be used to cancel grpc dial out and
	// other operations that do not have an explicit context.
	Context context.Context
}

type ProxyPool

type ProxyPool interface {
	GetProxy(context.Context, *v2.GetProxyRequest) (*v2.Proxy, error)
	DeleteProxy(context.Context, *v2.Proxy) error
}

func NewProxyPool

func NewProxyPool(c *Client) ProxyPool

type ValidateStreamResponse

type ValidateStreamResponse struct {
	ValidateRequest *v2.Proxy
	Created         bool
	Canceled        bool
	Err             error
	// contains filtered or unexported fields
}

type Validator

type Validator interface {
	ValidateStream(ctx context.Context, name string, validatedProxy <-chan *v2.Proxy) <-chan *ValidateStreamResponse
	Close() error
}

func NewValidator

func NewValidator(c *Client) Validator