Versions in this module Expand all Collapse all v0 v0.1.0 Dec 15, 2024 Changes in this version + const MetadataKeyConnectionName + const MetadataKeyStreamName + const MetadataKeyToken + func GetTokenInterceptor(ctx context.Context, req any, _ *grpc.UnaryServerInfo, ...) (resp any, err error) + func GetTokenStreamInterceptor(srv interface{}, ss grpc.ServerStream, _ *grpc.StreamServerInfo, ...) error + func WithLoggerInterceptor(logger logr.Logger) grpc.UnaryServerInterceptor + func WithLoggerStreamInterceptor(logger logr.Logger) grpc.StreamServerInterceptor + type AuthenticationServer struct + func NewAuthenticationServer(genericServer *generic.AuthenticationServer) *AuthenticationServer + func (s *AuthenticationServer) CreateSelfSubjectReview(ctx context.Context, review *authnv1grpc.SelfSubjectReview) (*authnv1grpc.SelfSubjectReview, error) + func (s *AuthenticationServer) CreateToken(ctx context.Context, req *authnv1grpc.TokenRequest) (*authnv1grpc.TokenRequest, error) + type StreamsServer struct + func NewStreamsServer(genericServer *generic.StreamsServer) *StreamsServer + func (s *StreamsServer) ConnectStream(server streamv1grpc.Streams_ConnectStreamServer) error + func (s *StreamsServer) CreateStream(ctx context.Context, stream *streamv1grpc.Stream) (*streamv1grpc.Stream, error) + func (s *StreamsServer) DeleteStream(ctx context.Context, req *streamv1grpc.DeleteStreamRequest) (*metav1grpc.Status, error) + func (s *StreamsServer) GetStream(ctx context.Context, req *streamv1grpc.GetStreamRequest) (*streamv1grpc.Stream, error) + func (s *StreamsServer) ListStreams(ctx context.Context, _ *streamv1grpc.ListStreamsRequest) (*streamv1grpc.StreamList, error)
Go to main page