ipc

Documentation

Index

• Variables
• type Client
  • func (c *Client) Call(rpc *hadoop_common.RequestHeaderProto, rpcRequest proto.Message, ...) error
  • func (c *Client) String() string

Variables

var (
	SASL_RPC_DUMMY_CLIENT_ID     []byte = make([]byte, 0)
	SASL_RPC_CALL_ID             int32  = -33
	SASL_RPC_INVALID_RETRY_COUNT int32  = -1
)

Types

type Client

type Client struct {
	ClientId      *uuid.UUID
	Ugi           *hadoop_common.UserInformationProto
	ServerAddress string
	TCPNoDelay    bool
}

func (*Client) Call

func (c *Client) Call(rpc *hadoop_common.RequestHeaderProto, rpcRequest proto.Message, rpcResponse proto.Message) error

func (*Client) String

func (c *Client) String() string