client

Documentation

Index

• Variables
• type Client
  • func NewClient(cfg Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) FramedTransport()
  • func (c *Client) In() thrift.TProtocol
  • func (c *Client) IsOpen() bool
  • func (c *Client) Open() error
  • func (c *Client) Out() thrift.TProtocol
  • func (c *Client) SetHeader(headers map[string]string)
  • func (c *Client) TClient() thrift.TClient
• type Config
• type Pool

Variables

var TransInvalidateERR = fmt.Errorf("transport invalidate")

Types

type Client

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

func NewClient

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

func (*Client) Close

func (c *Client) Close() error

func (*Client) FramedTransport

func (c *Client) FramedTransport()

func (*Client) In

func (c *Client) In() thrift.TProtocol

func (*Client) IsOpen

func (c *Client) IsOpen() bool

func (*Client) Open

func (c *Client) Open() error

func (*Client) Out

func (c *Client) Out() thrift.TProtocol

func (*Client) SetHeader

func (c *Client) SetHeader(headers map[string]string)

func (*Client) TClient

func (c *Client) TClient() thrift.TClient

type Config

type Config struct {
	Target   string `json:"target"`
	Protocol string `json:"protocol"`
}

type Pool

type Pool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}