client

Documentation

Index

• Constants
• func Reader(r io.Reader) interface{}
• type UnixSocketClient
  • func NewUnixSocketClient(runtimeConfig *config.RuntimeConfig) UnixSocketClient
  • func (client UnixSocketClient) Connect() (UnixSocketConnection, error)
  • func (client UnixSocketClient) SendToAgent(request interface{}) (interface{}, error)
• type UnixSocketConnection
  • func (conn UnixSocketConnection) Close()
  • func (conn UnixSocketConnection) ReadMessage() interface{}
  • func (conn UnixSocketConnection) SendCommand(request interface{}) (interface{}, error)
  • func (conn UnixSocketConnection) WriteMessage(message interface{}) error

Constants

const READ_BUFFER = 4 * 1024 * 1024 // 16MB

Functions

func Reader

func Reader(r io.Reader) interface{}

Types

type UnixSocketClient

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

func NewUnixSocketClient

func NewUnixSocketClient(runtimeConfig *config.RuntimeConfig) UnixSocketClient

func (UnixSocketClient) Connect

func (client UnixSocketClient) Connect() (UnixSocketConnection, error)

func (UnixSocketClient) SendToAgent

func (client UnixSocketClient) SendToAgent(request interface{}) (interface{}, error)

type UnixSocketConnection

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

func (UnixSocketConnection) Close

func (conn UnixSocketConnection) Close()

func (UnixSocketConnection) ReadMessage

func (conn UnixSocketConnection) ReadMessage() interface{}

func (UnixSocketConnection) SendCommand

func (conn UnixSocketConnection) SendCommand(request interface{}) (interface{}, error)

func (UnixSocketConnection) WriteMessage

func (conn UnixSocketConnection) WriteMessage(message interface{}) error