grpcx

Documentation

Index

• func Empty() *emptypb.Empty
• func TimestampToTimeP(in *timestamppb.Timestamp) *time.Time
• func Timestamppb(in *time.Time) *timestamppb.Timestamp
• func UInt64[T int64 | uint64](v T) *wrapperspb.UInt64Value
• type Interceptor
• type TokenAuth
  • func NewTokenAuth(token string) *TokenAuth
  • func (t *TokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error)
  • func (t *TokenAuth) RequireTransportSecurity() bool
  • func (t *TokenAuth) SetToken(token string)

Functions

func Empty

func Empty() *emptypb.Empty

func TimestampToTimeP

func TimestampToTimeP(in *timestamppb.Timestamp) *time.Time

func Timestamppb

func Timestamppb(in *time.Time) *timestamppb.Timestamp

func UInt64

func UInt64[T int64 | uint64](v T) *wrapperspb.UInt64Value

Types

type Interceptor

type Interceptor interface {
	UnrayInterceptor() []grpc.UnaryServerInterceptor
	StreamInterceptor() []grpc.StreamServerInterceptor
}

type TokenAuth

type TokenAuth struct {
	// contains filtered or unexported fields
}

Token client token authorizer...

func NewTokenAuth

func NewTokenAuth(token string) *TokenAuth

func (*TokenAuth) GetRequestMetadata

func (t *TokenAuth) GetRequestMetadata(ctx context.Context, in ...string) (map[string]string, error)

func (*TokenAuth) RequireTransportSecurity

func (t *TokenAuth) RequireTransportSecurity() bool

func (*TokenAuth) SetToken

func (t *TokenAuth) SetToken(token string)