internal

func NewFnReadWriter(
	r func(context.Context) (*goatorepo.Rpc, error),
	w func(context.Context, *goatorepo.Rpc) error,
) types.RpcReadWriter

func StatsEndRPC(
	statsHandlers []stats.Handler,
	isClient bool,
	beginTime time.Time,
	appErr error,
	ctx context.Context,
)

func StatsStartServerRPC(
	statsHandlers []stats.Handler,
	isClient bool,
	beginTime time.Time,
	method string,
	isClientStream bool,
	isServerStream bool,
	ctx context.Context,
) context.Context

func ToKeyValue(mds ...metadata.MD) []*goatorepo.KeyValue

func ToMetadata(kvs []*goatorepo.KeyValue) (metadata.MD, error)