grpc

Documentation

Index

• func DecodeConfigureRequest(_ context.Context, grpcReq interface{}) (interface{}, error)
• func DecodeConfigureResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func DecodeInitRequest(_ context.Context, grpcReq interface{}) (interface{}, error)
• func DecodeInitResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func DecodeInitStatusRequest(_ context.Context, grpcReq interface{}) (interface{}, error)
• func DecodeInitStatusResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func DecodeSealStatusRequest(_ context.Context, grpcReq interface{}) (interface{}, error)
• func DecodeSealStatusResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func DecodeUnsealRequest(_ context.Context, grpcReq interface{}) (interface{}, error)
• func DecodeUnsealResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func EncodeConfigureRequest(_ context.Context, request interface{}) (interface{}, error)
• func EncodeConfigureResponse(_ context.Context, response interface{}) (interface{}, error)
• func EncodeInitRequest(_ context.Context, request interface{}) (interface{}, error)
• func EncodeInitResponse(_ context.Context, response interface{}) (interface{}, error)
• func EncodeInitStatusRequest(_ context.Context, request interface{}) (interface{}, error)
• func EncodeInitStatusResponse(_ context.Context, response interface{}) (interface{}, error)
• func EncodeSealStatusRequest(_ context.Context, request interface{}) (interface{}, error)
• func EncodeSealStatusResponse(_ context.Context, response interface{}) (interface{}, error)
• func EncodeUnsealRequest(_ context.Context, request interface{}) (interface{}, error)
• func EncodeUnsealResponse(_ context.Context, response interface{}) (interface{}, error)
• func NewHandler(ctx context.Context, endpoints endpoints.Endpoints, ...) pb.VaultServer

Functions

func DecodeConfigureRequest

func DecodeConfigureRequest(_ context.Context, grpcReq interface{}) (interface{}, error)

DecodeConfigureRequest is a transport/grpc.DecodeRequestFunc that converts a gRPC configure request to a user-domain configure request. Primarily useful in a server.

func DecodeConfigureResponse

func DecodeConfigureResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeConfigureResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC configure reply to a user-domain configure response. Primarily useful in a client.

func DecodeInitRequest

func DecodeInitRequest(_ context.Context, grpcReq interface{}) (interface{}, error)

DecodeInitRequest is a transport/grpc.DecodeRequestFunc that converts a gRPC init request to a user-domain init request. Primarily useful in a server.

func DecodeInitResponse

func DecodeInitResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeInitResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC init reply to a user-domain init response. Primarily useful in a client.

func DecodeInitStatusRequest

func DecodeInitStatusRequest(_ context.Context, grpcReq interface{}) (interface{}, error)

DecodeInitStatusRequest is a transport/grpc.DecodeRequestFunc that converts a gRPC initstatus request to a user-domain initstatus request. Primarily useful in a server.

func DecodeInitStatusResponse

func DecodeInitStatusResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeInitStatusResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC initstatus reply to a user-domain initstatus response. Primarily useful in a client.

func DecodeSealStatusRequest

func DecodeSealStatusRequest(_ context.Context, grpcReq interface{}) (interface{}, error)

DecodeSealStatusRequest is a transport/grpc.DecodeRequestFunc that converts a gRPC sealstatus request to a user-domain sealstatus request. Primarily useful in a server.

func DecodeSealStatusResponse

func DecodeSealStatusResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeSealStatusResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC sealstatus reply to a user-domain sealstatus response. Primarily useful in a client.

func DecodeUnsealRequest

func DecodeUnsealRequest(_ context.Context, grpcReq interface{}) (interface{}, error)

DecodeUnsealRequest is a transport/grpc.DecodeRequestFunc that converts a gRPC unseal request to a user-domain unseal request. Primarily useful in a server.

func DecodeUnsealResponse

func DecodeUnsealResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeUnsealResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC unseal reply to a user-domain unseal response. Primarily useful in a client.

func EncodeConfigureRequest

func EncodeConfigureRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeConfigureRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain configure request to a gRPC configure request. Primarily useful in a client.

func EncodeConfigureResponse

func EncodeConfigureResponse(_ context.Context, response interface{}) (interface{}, error)

EncodeConfigureResponse is a transport/grpc.EncodeResponseFunc that converts a user-domain configure response to a gRPC configstatus reply. Primarily useful in a server.

func EncodeInitRequest

func EncodeInitRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeInitRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain init request to a gRPC init request. Primarily useful in a client.

func EncodeInitResponse

func EncodeInitResponse(_ context.Context, response interface{}) (interface{}, error)

EncodeInitResponse is a transport/grpc.EncodeResponseFunc that converts a user-domain init response to a gRPC init reply. Primarily useful in a server.

func EncodeInitStatusRequest

func EncodeInitStatusRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeInitStatusRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain initstatus request to a gRPC initstatus request. Primarily useful in a client.

func EncodeInitStatusResponse

func EncodeInitStatusResponse(_ context.Context, response interface{}) (interface{}, error)

EncodeInitStatusResponse is a transport/grpc.EncodeResponseFunc that converts a user-domain initstatus response to a gRPC initstatus reply. Primarily useful in a server.

func EncodeSealStatusRequest

func EncodeSealStatusRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeSealStatusRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain sealstatus request to a gRPC sealstatus request. Primarily useful in a client.

func EncodeSealStatusResponse

func EncodeSealStatusResponse(_ context.Context, response interface{}) (interface{}, error)

EncodeSealStatusResponse is a transport/grpc.EncodeResponseFunc that converts a user-domain sealstatus response to a gRPC sealstatus reply. Primarily useful in a server.

func EncodeUnsealRequest

func EncodeUnsealRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeUnsealRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain unseal request to a gRPC unseal request. Primarily useful in a client.

func EncodeUnsealResponse

func EncodeUnsealResponse(_ context.Context, response interface{}) (interface{}, error)

EncodeUnsealResponse is a transport/grpc.EncodeResponseFunc that converts a user-domain unseal response to a gRPC sealstatus reply. Primarily useful in a server.

func NewHandler

func NewHandler(ctx context.Context, endpoints endpoints.Endpoints, tracer stdopentracing.Tracer, logger log.Logger) pb.VaultServer

NewHandler makes a set of endpoints available as a gRPC Server. NOTE: At some point, request tracing support needs to be added. And since much of this service used example code from go-kit, the place to start for tracing support is probably here: https://github.com/go-kit/kit/blob/master/examples/addsvc/transport_grpc.go