grpcutil

Oct 20, 2022

Changes in this version

type CallMetadata

+ MethodName string

Oct 5, 2022

Changes in this version

type ServerOpt

+ func StreamInterceptor(interceptor grpc.StreamServerInterceptor) ServerOpt

+ func UnaryInterceptor(interceptor grpc.UnaryServerInterceptor) ServerOpt

Sep 2, 2022

Changes in this version

+ func GetClientIP(ctx context.Context) net.IP

+ func GetToken(ctx context.Context) string

+ func NewTokenCredentials(token string) credentials.PerRPCCredentials

+ type CallMetadata struct

+ FunctionName string

+ IP net.IP

+ type DuplexStream struct

+ func NewDuplexStream(stream grpc.ServerStream, opts ...DuplexStreamOpt) *DuplexStream[R, S]

+ func (ds *DuplexStream[R, S]) OnEnd(handler func(reason error))

+ func (ds *DuplexStream[R, S]) OnReceive(handler func(msg *R))

+ func (ds *DuplexStream[R, S]) Send(msg *S)

+ func (ds *DuplexStream[R, S]) Start() (err error)

+ func (ds *DuplexStream[R, S]) Stop()

+ type DuplexStreamConfig struct

+ type DuplexStreamOpt = func(config *DuplexStreamConfig)

+ func ReceiveChannelCapacity(capacity int64) DuplexStreamOpt

+ func SendChannelCapacity(capacity int64) DuplexStreamOpt

+ type Server struct

+ func NewServer(opts ...ServerOpt) *Server

+ func (s *Server) Start() error

+ func (s *Server) Stop()

+ type ServerOpt = func(*serverConfig)

+ func Address(address string) ServerOpt

+ func CustomConfig(customConfig *config.Config) ServerOpt

+ func EnableAuthMiddleware(verifier TokenVerifier) ServerOpt

+ func EnableAuthMiddlewareFunc(verifierFunc TokenVerifierFunc) ServerOpt

+ func ServerOptions(opts ...grpc.ServerOption) ServerOpt

+ type TokenVerificationResult struct

+ IsAuthorized bool

+ SessionData interface{}

+ func GetTokenVerificationResult(ctx context.Context) *TokenVerificationResult

+ type TokenVerifier interface

+ Verify func(token string, metadata *CallMetadata) (*TokenVerificationResult, error)

+ type TokenVerifierFunc func(token string, metadata *CallMetadata) (*TokenVerificationResult, error)