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, opts ...util.Mod[protojson.MarshalOptions]) ([]byte, error)
• func MarshalYAML[T proto.Message](in T, opts ...util.Mod[protojson.MarshalOptions]) ([]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, opts ...util.Mod[protojson.UnmarshalOptions]) (T, error)
• type GRPC
  • func NewGRPC[T proto.Message](in T) GRPC[T]
  • func (g GRPC[T]) MarshalJSON(opts ...util.Mod[protojson.MarshalOptions]) ([]byte, error)
  • func (g *GRPC[T]) UnmarshalJSON(data []byte, opts ...util.Mod[protojson.UnmarshalOptions]) error
• type HTTPResponse
  • func Get[T proto.Message](ctx context.Context, client operatorHTTP.HTTPClient, url string, ...) HTTPResponse[T]
  • func Post[IN, T proto.Message](ctx context.Context, client operatorHTTP.HTTPClient, in IN, url string, ...) HTTPResponse[T]
• 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, opts ...util.Mod[protojson.MarshalOptions]) ([]byte, error)

func MarshalYAML

func MarshalYAML[T proto.Message](in T, opts ...util.Mod[protojson.MarshalOptions]) ([]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, opts ...util.Mod[protojson.UnmarshalOptions]) (T, error)

Types

type GRPC

type GRPC[T proto.Message] struct {
	Object T
}

func NewGRPC

func NewGRPC[T proto.Message](in T) GRPC[T]

func (GRPC[T]) MarshalJSON

func (g GRPC[T]) MarshalJSON(opts ...util.Mod[protojson.MarshalOptions]) ([]byte, error)

func (*GRPC[T]) UnmarshalJSON

func (g *GRPC[T]) UnmarshalJSON(data []byte, opts ...util.Mod[protojson.UnmarshalOptions]) error

type HTTPResponse

type HTTPResponse[T proto.Message] interface {
	WithCode(codes ...int) HTTPResponse[T]
	Get() (T, error)
}

func Get

func Get[T proto.Message](ctx context.Context, client operatorHTTP.HTTPClient, url string, mods ...util.Mod[goHttp.Request]) HTTPResponse[T]

func Post

func Post[IN, T proto.Message](ctx context.Context, client operatorHTTP.HTTPClient, in IN, url string, mods ...util.Mod[goHttp.Request]) HTTPResponse[T]

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
}