rpc

Documentation

Index

• func NewShipper(cfg *env.Properties) shipper.Shipper
• type RpcShipper
  • func (p *RpcShipper) Init() error
  • func (p *RpcShipper) Send(v interface{})

Functions

func NewShipper

func NewShipper(cfg *env.Properties) shipper.Shipper

Types

type RpcShipper

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

func (*RpcShipper) Init

func (p *RpcShipper) Init() error

func (*RpcShipper) Send

func (p *RpcShipper) Send(v interface{})