cnclient

Documentation

Index

• func AcquireMessage() *pipeline.Message
• func CloseCNClient() error
• func GetRPCClient() morpc.RPCClient
• func GetStreamSender(backend string) (morpc.Stream, error)
• func IsCNClientReady() bool
• func NewCNClient(localServiceAddress string, cfg *ClientConfig) error
• type CNClient
  • func (c *CNClient) Close() error
  • func (c *CNClient) NewStream(backend string) (morpc.Stream, error)
• type ClientConfig
  • func (cfg *ClientConfig) Fill()

Functions

func AcquireMessage

func AcquireMessage() *pipeline.Message

func CloseCNClient

func CloseCNClient() error

func GetRPCClient

func GetRPCClient() morpc.RPCClient

func GetStreamSender

func GetStreamSender(backend string) (morpc.Stream, error)

func IsCNClientReady

func IsCNClientReady() bool

func NewCNClient

func NewCNClient(
	localServiceAddress string,
	cfg *ClientConfig) error

TODO: Here it needs to be refactored together with Runtime

Types

type CNClient

type CNClient struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*CNClient) Close

func (c *CNClient) Close() error

func (*CNClient) NewStream

func (c *CNClient) NewStream(backend string) (morpc.Stream, error)

type ClientConfig

type ClientConfig struct {
	// MaxSenderNumber is the max number of backends per host for compute node service.
	MaxSenderNumber int
	// TimeOutForEachConnect is the out time for each tcp connect.
	TimeOutForEachConnect time.Duration
	// related buffer size.
	ReadBufferSize  int
	WriteBufferSize int
	// RPC rpc config
	RPC rpc.Config
}

ClientConfig a config to init a CNClient

func (*ClientConfig) Fill

func (cfg *ClientConfig) Fill()

Fill set some default value for client config.