grpc

Documentation

Index

• Constants
• func ClientTLS(config *tls.Config) []grpc.DialOption
• func GRPCAnyCastAs[T proto.Message](in *anypb.Any, v T) error
• func Marshal[T proto.Message](in T) ([]byte, error)
• func MarshalYAML[T proto.Message](in T) ([]byte, error)
• func NewGRPCClient[T any](ctx context.Context, in func(cc grpc.ClientConnInterface) T, addr string, ...) (T, io.Closer, error)
• func NewGRPCConn(addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func NewOptionalTLSGRPCClient[T any](ctx context.Context, in func(cc grpc.ClientConnInterface) T, addr string, ...) (T, io.Closer, error)
• func NewOptionalTLSGRPCConn(ctx context.Context, addr string, tls *tls.Config, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func Recv[T any](recv RecvInterface[T], parser func(T) error) error
• func Send[T, O any](send SendInterface[T, O], batch func() (T, error)) (O, error)
• func TokenAuthInterceptors(token string) []grpc.DialOption
• func Unmarshal[T proto.Message](data []byte) (T, error)
• type RecvInterface
• type SendInterface

Constants

const AuthorizationGRPCHeader = "adb-authorization"

Functions

func ClientTLS

func ClientTLS(config *tls.Config) []grpc.DialOption

func GRPCAnyCastAs

func GRPCAnyCastAs[T proto.Message](in *anypb.Any, v T) error

func Marshal

func Marshal[T proto.Message](in T) ([]byte, error)

func MarshalYAML

func MarshalYAML[T proto.Message](in T) ([]byte, error)

func NewGRPCClient

func NewGRPCClient[T any](ctx context.Context, in func(cc grpc.ClientConnInterface) T, addr string, opts ...grpc.DialOption) (T, io.Closer, error)

func NewGRPCConn

func NewGRPCConn(addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func NewOptionalTLSGRPCClient

func NewOptionalTLSGRPCClient[T any](ctx context.Context, in func(cc grpc.ClientConnInterface) T, addr string, tls *tls.Config, opts ...grpc.DialOption) (T, io.Closer, error)

func NewOptionalTLSGRPCConn

func NewOptionalTLSGRPCConn(ctx context.Context, addr string, tls *tls.Config, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func Recv

func Recv[T any](recv RecvInterface[T], parser func(T) error) error

func Send

func Send[T, O any](send SendInterface[T, O], batch func() (T, error)) (O, error)

func TokenAuthInterceptors

func TokenAuthInterceptors(token string) []grpc.DialOption

func Unmarshal

func Unmarshal[T proto.Message](data []byte) (T, error)

Types

type RecvInterface

type RecvInterface[T any] interface {
	Recv() (T, error)
	grpc.ClientStream
}

type SendInterface

type SendInterface[T, O any] interface {
	Send(T) error
	CloseAndRecv() (O, error)
	grpc.ClientStream
}