ipc

Documentation

Index

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

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