tinygrpc

Nov 25, 2024

Changes in this version

+ type AuthProviderFunc func(c *CallContext) (context.Context, error)

+ func (f AuthProviderFunc) VerifyAuth(c *CallContext) (context.Context, error)

type CallContext

+ func (c *CallContext) Context() context.Context

+ type MultiAuthProvider struct

+ AllowUnauthenticated bool

+ EvaluateAll bool

+ Providers []AuthProvider

+ RequireAll bool

+ func (p *MultiAuthProvider) VerifyAuth(c *CallContext) (context.Context, error)

Nov 25, 2024

Changes in this version

+ func ExtractAuthMetadata(ctx context.Context, mdKey, schema string) (string, error)

type AuthHandler

+ func (h AuthHandler) VerifyAuth(c *CallContext) (context.Context, error)

type AuthProvider

+ VerifyAuth func(c *CallContext) (context.Context, error)

Nov 25, 2024

Changes in this version

type AuthHandler

+ func (h AuthHandler) Verify(c *CallContext, token string) (context.Context, error)

+ type AuthProvider interface

+ Verify func(c *CallContext, token string) (context.Context, error)

+ func ChainAuthProvider(providers ...AuthProvider) AuthProvider

+ func OptionalChainAuthProvider(providers ...AuthProvider) AuthProvider

Nov 14, 2024

Changes in this version

+ func StreamServerErrorDeterminer(determiner ErrorDeterminer) grpc.StreamServerInterceptor

+ func UnaryServerErrorDeterminer(determiner ErrorDeterminer) grpc.UnaryServerInterceptor

Nov 14, 2024

Changes in this version

+ const CallTypeBidiStream

+ const CallTypeClientStream

+ const CallTypeServerStream

+ const CallTypeUnary

+ func StreamServerAuthHandler(mdKey, schema string, authHandler AuthHandler) grpc.StreamServerInterceptor

+ func StreamServerContextInjector(injector ContextInjector) grpc.StreamServerInterceptor

+ func StreamServerLogger(logger *logrus.Logger, determiner LogLevelDeterminer, ...) grpc.StreamServerInterceptor

+ func StreamServerRecoveryHandler(recoveryHandler RecoveryHandler) grpc.StreamServerInterceptor

+ func StreamServerSelector(interceptor grpc.StreamServerInterceptor, matcher SelectorMatcher) grpc.StreamServerInterceptor

+ func UnaryServerAuthHandler(mdKey, schema string, authHandler AuthHandler) grpc.UnaryServerInterceptor

+ func UnaryServerContextInjector(injector ContextInjector) grpc.UnaryServerInterceptor

+ func UnaryServerLogger(logger *logrus.Logger, determiner LogLevelDeterminer) grpc.UnaryServerInterceptor

+ func UnaryServerRecoveryHandler(recoveryHandler RecoveryHandler) grpc.UnaryServerInterceptor

+ func UnaryServerSelector(interceptor grpc.UnaryServerInterceptor, matcher SelectorMatcher) grpc.UnaryServerInterceptor

+ type AuthHandler func(c *CallContext, token string) (context.Context, error)

+ type CallContext struct

+ CallType CallType

+ Ctx context.Context

+ FullMethod string

+ Server any

+ type CallType int

+ type ErrorDeterminer func(c *CallContext, err error) error

+ type LogLevelDeterminer func(c *CallContext, err error) logrus.Level

+ type RecoveryHandler func(c *CallContext, p any) error

+ type SelectorMatcher func(c *CallContext) bool

Nov 13, 2024

Changes in this version

+ func GracefulStop(grpcServer *grpc.Server, hook func(os.Signal)) chan struct

+ func LogrusKeySortingFunc(keys []string)

+ func NewStreamErrorInterceptor(determiner StreamErrorDeterminer) grpc.StreamServerInterceptor

+ func NewStreamLoggingInterceptor(logger *logrus.Logger, determiner StreamLogLevelDeterminer) grpc.StreamServerInterceptor

+ func NewUnaryErrorInterceptor(determiner UnaryErrorDeterminer) grpc.UnaryServerInterceptor

+ func NewUnaryLoggingInterceptor(logger *logrus.Logger, determiner UnaryLogLevelDeterminer) grpc.UnaryServerInterceptor

+ func StreamRecoveryInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) (retErr error)

+ func StreamWithContext(injector ContextInjector) grpc.StreamServerInterceptor

+ func UnaryRecoveryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (_ any, retErr error)

+ func UnaryWithContext(injector ContextInjector) grpc.UnaryServerInterceptor

+ type ContextInjector func(ctx context.Context) context.Context

+ type PanicWrapper struct

+ Panic any

+ Stack string

+ func (p PanicWrapper) Error() string

+ type StreamErrorDeterminer func(ctx context.Context, info *grpc.StreamServerInfo, err error) error

+ type StreamLogLevelDeterminer func(ctx context.Context, info *grpc.StreamServerInfo, err error) logrus.Level

+ type UnaryErrorDeterminer func(ctx context.Context, info *grpc.UnaryServerInfo, err error) error

+ type UnaryLogLevelDeterminer func(ctx context.Context, info *grpc.UnaryServerInfo, err error) logrus.Level