Versions in this module Expand all Collapse all v1 v1.7.0 Feb 14, 2023 Changes in this version + const AutoInjectLabel + const DeployLabel + const FileField + const HTTPRouteGroupKind + const IgnoreIncomingPortsField + const IgnoreOutgoingPortsField + const Injected + const InjectedAnnotation + const MeshAPI + const MeshCertReloader + const MeshConfigFileName + const MeshConfigMap + const MeshSidecar + const MeshSidecarInit + const MetricsDeployment + const MetricsService + const MetricsServiceAccount + const NatsAPIPingChannel + const NatsAgentConfigChannel + const NatsAgentSubChannel + const NatsServer + const TCPRouteKind + var Environments = map[string]struct + var IgnoredNamespaces = map[string]bool + var LoadBalancingMethods = map[string]struct + var MtlsModes = map[string]struct + var NGINXLogFormats = map[string]struct + var TracingBackends = map[string]struct + func GetSwagger() (swagger *openapi3.T, err error) + func NewGetConfigRequest(server string) (*http.Request, error) + func NewGetServicesRequest(server string) (*http.Request, error) + func NewInjectSidecarProxyRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error) + func NewPatchConfigRequest(server string, body PatchConfigJSONRequestBody) (*http.Request, error) + func NewPatchConfigRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error) + func ParseAPIError(res *http.Response) error + func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error) + func RegisterHandlers(router EchoRouter, si ServerInterface) + func RegisterHandlersWithBaseURL(router EchoRouter, si ServerInterface, baseURL string) + type APIConfig struct + Address string + ContainerPort int + Port int + type BadRequest = ErrorModel + type Client struct + Client HttpRequestDoer + RequestEditors []RequestEditorFn + Server string + func NewClient(server string, opts ...ClientOption) (*Client, error) + func NewMeshClient(config *rest.Config, timeout time.Duration) (*Client, error) + func (c *Client) GetConfig(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetServices(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) InjectSidecarProxyWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + func (c *Client) PatchConfig(ctx context.Context, body PatchConfigJSONRequestBody, ...) (*http.Response, error) + func (c *Client) PatchConfigWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + type ClientInterface interface + GetConfig func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + GetServices func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + InjectSidecarProxyWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + PatchConfig func(ctx context.Context, body PatchConfigJSONRequestBody, ...) (*http.Response, error) + PatchConfigWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + type ClientOption func(*Client) error + func WithBaseURL(baseURL string) ClientOption + func WithHTTPClient(doer HttpRequestDoer) ClientOption + func WithRequestEditorFn(fn RequestEditorFn) ClientOption + type ClientWithResponses struct + func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error) + func (c *ClientWithResponses) GetConfigWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetConfigResponse, error) + func (c *ClientWithResponses) GetServicesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetServicesResponse, error) + func (c *ClientWithResponses) InjectSidecarProxyWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*InjectSidecarProxyResponse, error) + func (c *ClientWithResponses) PatchConfigWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*PatchConfigResponse, error) + func (c *ClientWithResponses) PatchConfigWithResponse(ctx context.Context, body PatchConfigJSONRequestBody, ...) (*PatchConfigResponse, error) + type ClientWithResponsesInterface interface + GetConfigWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetConfigResponse, error) + GetServicesWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetServicesResponse, error) + InjectSidecarProxyWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*InjectSidecarProxyResponse, error) + PatchConfigWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*PatchConfigResponse, error) + PatchConfigWithResponse func(ctx context.Context, body PatchConfigJSONRequestBody, ...) (*PatchConfigResponse, error) + type EchoRouter interface + CONNECT func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + DELETE func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + GET func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + HEAD func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + OPTIONS func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + PATCH func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + POST func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + PUT func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + TRACE func(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route + type ErrorDetail struct + Description string + type ErrorModel struct + Code int + Details *[]ErrorDetail + Message string + type ExportersConfig struct + Otlp *OtlpExporterConfig + type Forbidden = ErrorModel + type GetConfigResponse struct + Body []byte + HTTPResponse *http.Response + JSON200 *MeshConfig + JSON401 *ErrorModel + JSON403 *ErrorModel + JSON500 *ErrorModel + func ParseGetConfigResponse(rsp *http.Response) (*GetConfigResponse, error) + func (r GetConfigResponse) Status() string + func (r GetConfigResponse) StatusCode() int + type GetServicesResponse struct + Body []byte + HTTPResponse *http.Response + JSON200 *[]Service + JSON401 *ErrorModel + JSON403 *ErrorModel + JSON500 *ErrorModel + func ParseGetServicesResponse(rsp *http.Response) (*GetServicesResponse, error) + func (r GetServicesResponse) Status() string + func (r GetServicesResponse) StatusCode() int + type HttpRequestDoer interface + Do func(req *http.Request) (*http.Response, error) + type Image struct + Image string + Name string + type InjectConfig struct + DisabledNamespaces *[]string + EnabledNamespaces *[]string + IsAutoInjectEnabled *bool + type InjectSidecarProxyMultipartBody struct + File openapi_types.File + IgnoreIncomingPorts *[]string + IgnoreOutgoingPorts *[]string + type InjectSidecarProxyMultipartRequestBody InjectSidecarProxyMultipartBody + type InjectSidecarProxyResponse struct + Body []byte + HTTPResponse *http.Response + JSON400 *ErrorModel + JSON401 *ErrorModel + JSON403 *ErrorModel + JSON500 *ErrorModel + func ParseInjectSidecarProxyResponse(rsp *http.Response) (*InjectSidecarProxyResponse, error) + func (r InjectSidecarProxyResponse) Status() string + func (r InjectSidecarProxyResponse) StatusCode() int + type InternalServerError = ErrorModel + type MeshConfig struct + AccessControlMode MeshConfigAccessControlMode + Api APIConfig + AutoInjectorPort int + ClientMaxBodySize string + EnabledNamespaces *[]string + Environment MeshConfigEnvironment + Injection InjectConfig + IsAutoInjectEnabled *bool + IsUDPEnabled bool + LoadBalancingMethod MeshConfigLoadBalancingMethod + Mtls MtlsConfig + Namespace string + NginxErrorLogLevel MeshConfigNginxErrorLogLevel + NginxLogFormat MeshConfigNginxLogFormat + PrometheusAddress string + Proxy ProxyConfig + RegistryKeyName string + SidecarImage Image + SidecarInitImage Image + Telemetry TelemetryConfig + Tracing TraceConfig + TrustDomain string + func (config *MeshConfig) CheckForInvalidConfig(k8sClient client.Client) error + type MeshConfigAccessControlMode string + const MeshConfigAccessControlModeAllow + const MeshConfigAccessControlModeDeny + type MeshConfigEnvironment string + const Kubernetes + const Openshift + type MeshConfigLoadBalancingMethod string + const MeshConfigLoadBalancingMethodLeastConn + const MeshConfigLoadBalancingMethodLeastTime + const MeshConfigLoadBalancingMethodLeastTimeLastByte + const MeshConfigLoadBalancingMethodLeastTimeLastByteInflight + const MeshConfigLoadBalancingMethodRandom + const MeshConfigLoadBalancingMethodRandomTwo + const MeshConfigLoadBalancingMethodRandomTwoLeastConn + const MeshConfigLoadBalancingMethodRandomTwoLeastTime + const MeshConfigLoadBalancingMethodRandomTwoLeastTimeLastByte + const MeshConfigLoadBalancingMethodRoundRobin + type MeshConfigNginxErrorLogLevel string + const MeshConfigNginxErrorLogLevelAlert + const MeshConfigNginxErrorLogLevelCrit + const MeshConfigNginxErrorLogLevelDebug + const MeshConfigNginxErrorLogLevelEmerg + const MeshConfigNginxErrorLogLevelError + const MeshConfigNginxErrorLogLevelInfo + const MeshConfigNginxErrorLogLevelNotice + const MeshConfigNginxErrorLogLevelWarn + type MeshConfigNginxLogFormat string + const MeshConfigNginxLogFormatDefault + const MeshConfigNginxLogFormatJson + type MetricsConfig struct + PromAddr *string + type MtlsConfig struct + CaKeyType *MtlsConfigCaKeyType + CaTTL *string + Mode *MtlsConfigMode + SvidTTL *string + type MtlsConfigCaKeyType string + const EcP256 + const EcP384 + const Rsa2048 + const Rsa4096 + type MtlsConfigMode string + const Off + const Permissive + const Strict + type OtlpExporterConfig struct + Host string + Port int + type PatchConfig struct + Field struct{ ... } + Op PatchConfigOp + type PatchConfigFieldAccessControlMode string + const PatchConfigFieldAccessControlModeAllow + const PatchConfigFieldAccessControlModeDeny + type PatchConfigFieldLoadBalancingMethod string + const PatchConfigFieldLoadBalancingMethodLeastConn + const PatchConfigFieldLoadBalancingMethodLeastTime + const PatchConfigFieldLoadBalancingMethodLeastTimeLastByte + const PatchConfigFieldLoadBalancingMethodLeastTimeLastByteInflight + const PatchConfigFieldLoadBalancingMethodRandom + const PatchConfigFieldLoadBalancingMethodRandomTwo + const PatchConfigFieldLoadBalancingMethodRandomTwoLeastConn + const PatchConfigFieldLoadBalancingMethodRandomTwoLeastTime + const PatchConfigFieldLoadBalancingMethodRandomTwoLeastTimeLastByte + const PatchConfigFieldLoadBalancingMethodRoundRobin + type PatchConfigFieldNginxErrorLogLevel string + const PatchConfigFieldNginxErrorLogLevelAlert + const PatchConfigFieldNginxErrorLogLevelCrit + const PatchConfigFieldNginxErrorLogLevelDebug + const PatchConfigFieldNginxErrorLogLevelEmerg + const PatchConfigFieldNginxErrorLogLevelError + const PatchConfigFieldNginxErrorLogLevelInfo + const PatchConfigFieldNginxErrorLogLevelNotice + const PatchConfigFieldNginxErrorLogLevelWarn + type PatchConfigFieldNginxLogFormat string + const PatchConfigFieldNginxLogFormatDefault + const PatchConfigFieldNginxLogFormatJson + type PatchConfigJSONBody struct + type PatchConfigJSONBody1 = []PatchConfig + type PatchConfigJSONRequestBody PatchConfigJSONBody + type PatchConfigOp string + const Add + const Remove + const Replace + type PatchConfigResponse struct + Body []byte + HTTPResponse *http.Response + JSON200 *MeshConfig + JSON400 *ErrorModel + JSON401 *ErrorModel + JSON403 *ErrorModel + func ParsePatchConfigResponse(rsp *http.Response) (*PatchConfigResponse, error) + func (r PatchConfigResponse) Status() string + func (r PatchConfigResponse) StatusCode() int + type PortsConfig struct + Incoming int + IncomingGrpc int + IncomingGrpcPermissive int + IncomingNotInKeyval int + IncomingPermissive int + IncomingRedirect int + IncomingTcp int + IncomingTcpDeny int + IncomingTcpPermissive int + IncomingUdp int + Metrics int + Outgoing int + OutgoingDefaultEgress int + OutgoingGrpc int + OutgoingNotInKeyval int + OutgoingRedirect int + OutgoingTcp int + OutgoingUdp int + PlusApi int + RedirectHealthPort int + RedirectHealthPortHTTPS int + type ProxiedResources map[string]map[string][]string + type ProxyConfig struct + Ports PortsConfig + Transparent bool + type RequestEditorFn func(ctx context.Context, req *http.Request) error + type ServerInterface interface + GetConfig func(ctx echo.Context) error + GetServices func(ctx echo.Context) error + InjectSidecarProxy func(ctx echo.Context) error + PatchConfig func(ctx echo.Context) error + type ServerInterfaceWrapper struct + Handler ServerInterface + func (w *ServerInterfaceWrapper) GetConfig(ctx echo.Context) error + func (w *ServerInterfaceWrapper) GetServices(ctx echo.Context) error + func (w *ServerInterfaceWrapper) InjectSidecarProxy(ctx echo.Context) error + func (w *ServerInterfaceWrapper) PatchConfig(ctx echo.Context) error + type Service struct + Addresses []string + Name string + Namespace *string + Ports []ServicePort + ServiceIP *string + type ServicePort struct + Port int32 + Protocol string + type TelemetryConfig struct + Exporters *ExportersConfig + SamplerRatio *float32 + type TraceConfig struct + Backend *TraceConfigBackend + BackendAddress *string + SampleRate *float32 + type TraceConfigBackend string + const Datadog + const Jaeger + const Zipkin + type Unauthorized = ErrorModel
Go to main page