grpc

Documentation

Index

• Constants
• 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
  • 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
  • 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)

Constants

const (
	// MetadataKeyStreamName 表示流名的 metadata 键
	MetadataKeyStreamName = "scaf-stream-name"
	// MetadataKeyConnectionName 表示连接名的 metadata 键
	MetadataKeyConnectionName = "scaf-connection-name"
	// MetadataKeyToken 表示 Token 的 metadata 键
	MetadataKeyToken = "scaf-token"
)

Functions

func GetTokenInterceptor

func GetTokenInterceptor(
	ctx context.Context,
	req any,
	_ *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (resp any, err error)

GetTokenInterceptor 获取 Token 的拦截器

func GetTokenStreamInterceptor

func GetTokenStreamInterceptor(
	srv interface{},
	ss grpc.ServerStream,
	_ *grpc.StreamServerInfo,
	handler grpc.StreamHandler,
) error

GetTokenStreamInterceptor 获取 Token 的拦截器

func WithLoggerInterceptor

func WithLoggerInterceptor(logger logr.Logger) grpc.UnaryServerInterceptor

WithLoggerInterceptor 往上下文注入 logr.Logger 的拦截器

func WithLoggerStreamInterceptor

func WithLoggerStreamInterceptor(logger logr.Logger) grpc.StreamServerInterceptor

WithLoggerStreamInterceptor 往上下文注入 logr.Logger 的拦截器

Types

type AuthenticationServer

type AuthenticationServer struct {
	authnv1grpc.UnimplementedAuthenticationServer
	// contains filtered or unexported fields
}

AuthenticationServer 认证服务

func NewAuthenticationServer

func NewAuthenticationServer(genericServer *generic.AuthenticationServer) *AuthenticationServer

NewAuthenticationServer 创建 gRPC 认证服务

func (*AuthenticationServer) CreateSelfSubjectReview

func (s *AuthenticationServer) CreateSelfSubjectReview(
	ctx context.Context,
	review *authnv1grpc.SelfSubjectReview,
) (*authnv1grpc.SelfSubjectReview, error)

CreateSelfSubjectReview 检查自身身份

func (*AuthenticationServer) CreateToken

func (s *AuthenticationServer) CreateToken(
	ctx context.Context,
	req *authnv1grpc.TokenRequest,
) (*authnv1grpc.TokenRequest, error)

CreateToken 创建 Token

type StreamsServer

type StreamsServer struct {
	streamv1grpc.UnimplementedStreamsServer
	// contains filtered or unexported fields
}

StreamsServer 流服务

func NewStreamsServer

func NewStreamsServer(genericServer *generic.StreamsServer) *StreamsServer

NewStreamsServer 创建 gRPC 流服务

func (*StreamsServer) ConnectStream

func (s *StreamsServer) ConnectStream(server streamv1grpc.Streams_ConnectStreamServer) error

ConnectStream 连接流

func (*StreamsServer) CreateStream

func (s *StreamsServer) CreateStream(ctx context.Context, stream *streamv1grpc.Stream) (*streamv1grpc.Stream, error)

CreateStream 创建流

func (*StreamsServer) DeleteStream

func (s *StreamsServer) DeleteStream(
	ctx context.Context,
	req *streamv1grpc.DeleteStreamRequest,
) (*metav1grpc.Status, error)

DeleteStream 删除流

func (*StreamsServer) GetStream

func (s *StreamsServer) GetStream(
	ctx context.Context,
	req *streamv1grpc.GetStreamRequest,
) (*streamv1grpc.Stream, error)

GetStream 获取流

func (*StreamsServer) ListStreams

func (s *StreamsServer) ListStreams(
	ctx context.Context,
	_ *streamv1grpc.ListStreamsRequest,
) (*streamv1grpc.StreamList, error)

ListStreams 列出流