Documentation
¶
Index ¶
- Constants
- Variables
- func ClientStreamInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)
- func ClientUnaryInterceptor(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, ...) error
- func ServerStreamInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
- func ServerUnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (any, error)
Constants ¶
View Source
const ( MetadataKeyClientVersion = "uncloud-client-version" MetadataKeyMinServerVersion = "uncloud-min-server-version" MetadataKeyServerVersion = "uncloud-server-version" // MinClientVersion is the minimum client version the daemon accepts. The daemon // rejects requests from older clients, forcing them to upgrade. This provides // a clean cut-off for dropping support for old clients. // // MinServerVersion is the minimum daemon version the client requires. The client // sends this with each request so the daemon can immediately reject if it's too old, // avoiding the need for a preflight request. This is useful when a new client feature // requires daemon capabilities that didn't exist in older versions. // // The two minimums are independent: a client might require a newer daemon for new // features, while that same daemon could still handle requests from older clients. MinClientVersion = "0.0.0" MinServerVersion = "0.0.0" ReleaseURL = "https://github.com/psviderski/uncloud/releases/latest" )
Variables ¶
View Source
var ( // WarnWriter is the writer used for version mismatch warnings. Defaults to os.Stderr. // Tests can override this to capture warning output. WarnWriter io.Writer = os.Stderr )
Functions ¶
func ClientStreamInterceptor ¶
func ClientStreamInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)
func ClientUnaryInterceptor ¶
func ClientUnaryInterceptor(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error
func ServerStreamInterceptor ¶
func ServerStreamInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
func ServerUnaryInterceptor ¶
func ServerUnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (any, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.