The highest tagged major version is
Documentation
¶
Index ¶
- Constants
- Variables
- func GetVersionHeaderClientUnaryInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
- func IncomingHeaderMatcher(key string) (string, bool)
- func NewMuxHandler(grpcServerHandler http.Handler, httpServerHandler http.Handler) http.Handler
- func PanicLoggerStreamServerInterceptor(log *log.Entry) grpc.StreamServerInterceptor
- func PanicLoggerUnaryServerInterceptor(log *log.Entry) grpc.UnaryServerInterceptor
- func RatelimitStreamServerInterceptor(ratelimiter limiter.Store) grpc.StreamServerInterceptor
- func RatelimitUnaryServerInterceptor(ratelimiter limiter.Store) grpc.UnaryServerInterceptor
- func SetVersionHeaderStreamServerInterceptor(version wfv1.Version) grpc.StreamServerInterceptor
- func SetVersionHeaderUnaryServerInterceptor(version wfv1.Version) grpc.UnaryServerInterceptor
- func TranslateError(err error) error
Constants ¶
const (
ArgoVersionHeader = "argo-version"
)
Variables ¶
var ( LastSeenServerVersion string ErrorTranslationUnaryServerInterceptor = func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error) { resp, err = handler(ctx, req) return resp, TranslateError(err) } ErrorTranslationStreamServerInterceptor = func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error { return TranslateError(handler(srv, ss)) } )
Functions ¶
func GetVersionHeaderClientUnaryInterceptor ¶ added in v3.6.0
func GetVersionHeaderClientUnaryInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error
GetVersionHeaderClientUnaryInterceptor returns a new unary client interceptor that extracts the argo-version from the response and sets the global variable LastSeenServerVersion
func IncomingHeaderMatcher ¶ added in v3.6.11
func NewMuxHandler ¶ added in v3.6.11
NewMuxHandler returns an HTTP handler that allows serving both gRPC and HTTP requests over the same port, both with and without TLS enabled.
To serve unencrypted (h2c) gRPC requests, the returned handler must be served by an http.Server whose Protocols field enables UnencryptedHTTP2 (see http.Protocols.SetUnencryptedHTTP2). This replaces the deprecated golang.org/x/net/http2/h2c.NewHandler wrapper.
func PanicLoggerStreamServerInterceptor ¶
func PanicLoggerStreamServerInterceptor(log *log.Entry) grpc.StreamServerInterceptor
PanicLoggerStreamServerInterceptor returns a new streaming server interceptor for recovering from panics and returning error
func PanicLoggerUnaryServerInterceptor ¶
func PanicLoggerUnaryServerInterceptor(log *log.Entry) grpc.UnaryServerInterceptor
PanicLoggerUnaryServerInterceptor returns a new unary server interceptor for recovering from panics and returning error
func RatelimitStreamServerInterceptor ¶ added in v3.4.0
func RatelimitStreamServerInterceptor(ratelimiter limiter.Store) grpc.StreamServerInterceptor
RatelimitStreamServerInterceptor returns a new stream server interceptor that performs rate limiting on the request.
func RatelimitUnaryServerInterceptor ¶ added in v3.4.0
func RatelimitUnaryServerInterceptor(ratelimiter limiter.Store) grpc.UnaryServerInterceptor
RatelimitUnaryServerInterceptor returns a new unary server interceptor that performs request rate limiting.
func SetVersionHeaderStreamServerInterceptor ¶ added in v3.6.0
func SetVersionHeaderStreamServerInterceptor(version wfv1.Version) grpc.StreamServerInterceptor
SetVersionHeaderStreamServerInterceptor returns a new stream server interceptor that sets the argo-version header
func SetVersionHeaderUnaryServerInterceptor ¶ added in v3.6.0
func SetVersionHeaderUnaryServerInterceptor(version wfv1.Version) grpc.UnaryServerInterceptor
SetVersionHeaderUnaryServerInterceptor returns a new unary server interceptor that sets the argo-version header
func TranslateError ¶
translate a K8S errors into gRPC error - assume that we want to surface this - which we may not
Types ¶
This section is empty.
Source Files