rpc

Documentation

Index

• func CallAllReplicas(ctx context.Context, clients []interface{}, replicaFuncs []CallFunc, ...) (reply interface{}, err error)
• func ContextPropagationUnaryClientInterceptor() grpc.UnaryClientInterceptor
• func ContextPropagationUnaryServerInterceptor() grpc.UnaryServerInterceptor
• type CallFunc

Functions

func CallAllReplicas

func CallAllReplicas(ctx context.Context, clients []interface{}, replicaFuncs []CallFunc, request interface{}) (reply interface{}, err error)

TODO: move previous tests for calling all replicas to this package

func ContextPropagationUnaryClientInterceptor

func ContextPropagationUnaryClientInterceptor() grpc.UnaryClientInterceptor

func ContextPropagationUnaryServerInterceptor

func ContextPropagationUnaryServerInterceptor() grpc.UnaryServerInterceptor

Types

type CallFunc

type CallFunc func(ctx context.Context, client interface{}, request interface{}, opts ...grpc.CallOption) (interface{}, error)