type RPCService interface {
PipeCreate(ctx context.Context, in *PipeCreate) (*PipeCreateReply, error)
PipeDelete(ctx context.Context, in *PipeDelete) (*PipeDeleteReply, error)
type RPCService interface {
PipeCreate(ctx context.Context, in *PipeCreate) (*PipeCreateReply, error)
PipeDelete(ctx context.Context, in *PipeDelete) (*PipeDeleteReply, error)