grpc

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(cfg Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Execute(ctx context.Context, shell string, opts ...client.ExecOption) (client.ICmd, error)
  • func (c *Client) Get(ctx context.Context, src, dst string, opts ...client.GetOption) (err error)
  • func (c *Client) Name() string
  • func (c *Client) Put(ctx context.Context, src, dst string, opts ...client.PutOption) (err error)
  • func (c *Client) ReadFile(ctx context.Context, name string) (data []byte, err error)
  • func (c *Client) Stat(ctx context.Context, name string) (*client.Stat, error)
• type Cmd
  • func (c *Cmd) Close() error
  • func (c *Cmd) CombinedOutput() ([]byte, error)
  • func (c *Cmd) Run() error
  • func (c *Cmd) Start() error
  • func (c *Cmd) StderrPipe() (io.Reader, error)
  • func (c *Cmd) StdinPipe() (io.WriteCloser, error)
  • func (c *Cmd) StdoutPipe() (io.Reader, error)
  • func (c *Cmd) Wait() error
• type Config
  • func NewConfig(lg *zap.Logger, addr string) *Config
  • func (cfg *Config) Validate() error

Constants

const (
	DefaultGRPCPort = 15450
	DefaultPoolSize = 10
	DefaultPoolTTL  = time.Minute
	// DefaultPoolMaxStreams maximum streams on a connections (20)
	DefaultPoolMaxStreams = 20

	// DefaultPoolMaxIdle maximum idle conns of a pool (50)
	DefaultPoolMaxIdle = 50
)

Variables

var (
	ErrAlreadyStarted = errors.New("cmd already started")
	ErrNotStarted     = errors.New("cmd not started")
)

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) Execute

func (c *Client) Execute(ctx context.Context, shell string, opts ...client.ExecOption) (client.ICmd, error)

func (*Client) Get

func (c *Client) Get(ctx context.Context, src, dst string, opts ...client.GetOption) (err error)

func (*Client) Name

func (c *Client) Name() string

func (*Client) Put

func (c *Client) Put(ctx context.Context, src, dst string, opts ...client.PutOption) (err error)

func (*Client) ReadFile

func (c *Client) ReadFile(ctx context.Context, name string) (data []byte, err error)

func (*Client) Stat

func (c *Client) Stat(ctx context.Context, name string) (*client.Stat, error)

type Cmd

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

func (*Cmd) Close

func (c *Cmd) Close() error

func (*Cmd) CombinedOutput

func (c *Cmd) CombinedOutput() ([]byte, error)

func (*Cmd) Run

func (c *Cmd) Run() error

func (*Cmd) Start

func (c *Cmd) Start() error

func (*Cmd) StderrPipe

func (c *Cmd) StderrPipe() (io.Reader, error)

func (*Cmd) StdinPipe

func (c *Cmd) StdinPipe() (io.WriteCloser, error)

func (*Cmd) StdoutPipe

func (c *Cmd) StdoutPipe() (io.Reader, error)

func (*Cmd) Wait

func (c *Cmd) Wait() error

type Config

type Config struct {
	Address string
	Timeout time.Duration
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(lg *zap.Logger, addr string) *Config

func (*Config) Validate

func (cfg *Config) Validate() error