checkhttpv1

package
v2.25.2-rc.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 1, 2023 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Overview

Package checkhttpv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	FlowControlServiceHTTP_CheckHTTP_FullMethodName = "/aperture.flowcontrol.checkhttp.v1.FlowControlServiceHTTP/CheckHTTP"
)

Variables

View Source
var (
	SocketAddress_Protocol_name = map[int32]string{
		0: "TCP",
		1: "UDP",
	}
	SocketAddress_Protocol_value = map[string]int32{
		"TCP": 0,
		"UDP": 1,
	}
)

Enum value maps for SocketAddress_Protocol.

View Source
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var File_aperture_flowcontrol_checkhttp_v1_checkhttp_proto protoreflect.FileDescriptor
View Source
var FlowControlServiceHTTP_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aperture.flowcontrol.checkhttp.v1.FlowControlServiceHTTP",
	HandlerType: (*FlowControlServiceHTTPServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CheckHTTP",
			Handler:    _FlowControlServiceHTTP_CheckHTTP_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aperture/flowcontrol/checkhttp/v1/checkhttp.proto",
}

FlowControlServiceHTTP_ServiceDesc is the grpc.ServiceDesc for FlowControlServiceHTTP service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFlowControlServiceHTTPHandler

func RegisterFlowControlServiceHTTPHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFlowControlServiceHTTPHandler registers the http handlers for service FlowControlServiceHTTP to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFlowControlServiceHTTPHandlerClient

func RegisterFlowControlServiceHTTPHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FlowControlServiceHTTPClient) error

RegisterFlowControlServiceHTTPHandlerClient registers the http handlers for service FlowControlServiceHTTP to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FlowControlServiceHTTPClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FlowControlServiceHTTPClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FlowControlServiceHTTPClient" to call the correct interceptors.

func RegisterFlowControlServiceHTTPHandlerFromEndpoint

func RegisterFlowControlServiceHTTPHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFlowControlServiceHTTPHandlerFromEndpoint is same as RegisterFlowControlServiceHTTPHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFlowControlServiceHTTPHandlerServer

func RegisterFlowControlServiceHTTPHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FlowControlServiceHTTPServer) error

RegisterFlowControlServiceHTTPHandlerServer registers the http handlers for service FlowControlServiceHTTP to "mux". UnaryRPC :call FlowControlServiceHTTPServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterFlowControlServiceHTTPHandlerFromEndpoint instead.

func RegisterFlowControlServiceHTTPServer

func RegisterFlowControlServiceHTTPServer(s grpc.ServiceRegistrar, srv FlowControlServiceHTTPServer)

Types

type CheckHTTPRequest

type CheckHTTPRequest struct {

	// The source of a network activity, such as starting a TCP connection.
	// In a multi hop network activity, the source represents the sender of the
	// last hop.
	Source *SocketAddress `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// The destination of a network activity, such as accepting a TCP connection.
	// In a multi hop network activity, the destination represents the receiver of
	// the last hop.
	Destination *SocketAddress `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	// Represents a network request, such as an HTTP request.
	Request *CheckHTTPRequest_HttpRequest `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	// For an SDK based insertion, a Control Point can represent a particular feature or execution block within a Service.
	// In case of Service Mesh or Middleware insertion, a Control Point can identify ingress vs egress calls or distinct listeners or filter chains.
	ControlPoint string `protobuf:"bytes,4,opt,name=control_point,json=controlPoint,proto3" json:"control_point,omitempty"`
	// A flow with ramp_mode flag will only be accepted if at least one ramp component matches and accepts the flow.
	RampMode bool `protobuf:"varint,5,opt,name=ramp_mode,json=rampMode,proto3" json:"ramp_mode,omitempty"`
	// contains filtered or unexported fields
}

func CheckHTTPRequestFromVTPool added in v2.7.0

func CheckHTTPRequestFromVTPool() *CheckHTTPRequest

func (*CheckHTTPRequest) Descriptor deprecated

func (*CheckHTTPRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckHTTPRequest.ProtoReflect.Descriptor instead.

func (*CheckHTTPRequest) GetControlPoint

func (x *CheckHTTPRequest) GetControlPoint() string

func (*CheckHTTPRequest) GetDestination

func (x *CheckHTTPRequest) GetDestination() *SocketAddress

func (*CheckHTTPRequest) GetRampMode added in v2.17.0

func (x *CheckHTTPRequest) GetRampMode() bool

func (*CheckHTTPRequest) GetRequest

func (*CheckHTTPRequest) GetSource

func (x *CheckHTTPRequest) GetSource() *SocketAddress

func (*CheckHTTPRequest) MarshalJSON

func (msg *CheckHTTPRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CheckHTTPRequest) MarshalToSizedBufferVT added in v2.7.0

func (m *CheckHTTPRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckHTTPRequest) MarshalToVT added in v2.7.0

func (m *CheckHTTPRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CheckHTTPRequest) MarshalVT added in v2.7.0

func (m *CheckHTTPRequest) MarshalVT() (dAtA []byte, err error)

func (*CheckHTTPRequest) ProtoMessage

func (*CheckHTTPRequest) ProtoMessage()

func (*CheckHTTPRequest) ProtoReflect

func (x *CheckHTTPRequest) ProtoReflect() protoreflect.Message

func (*CheckHTTPRequest) Reset

func (x *CheckHTTPRequest) Reset()

func (*CheckHTTPRequest) ResetVT added in v2.7.0

func (m *CheckHTTPRequest) ResetVT()

func (*CheckHTTPRequest) ReturnToVTPool added in v2.7.0

func (m *CheckHTTPRequest) ReturnToVTPool()

func (*CheckHTTPRequest) SizeVT added in v2.7.0

func (m *CheckHTTPRequest) SizeVT() (n int)

func (*CheckHTTPRequest) String

func (x *CheckHTTPRequest) String() string

func (*CheckHTTPRequest) UnmarshalJSON

func (msg *CheckHTTPRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*CheckHTTPRequest) UnmarshalVT added in v2.7.0

func (m *CheckHTTPRequest) UnmarshalVT(dAtA []byte) error

func (*CheckHTTPRequest) Validate

func (m *CheckHTTPRequest) Validate() error

Validate checks the field values on CheckHTTPRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CheckHTTPRequest) ValidateAll

func (m *CheckHTTPRequest) ValidateAll() error

ValidateAll checks the field values on CheckHTTPRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CheckHTTPRequestMultiError, or nil if none found.

type CheckHTTPRequestMultiError

type CheckHTTPRequestMultiError []error

CheckHTTPRequestMultiError is an error wrapping multiple validation errors returned by CheckHTTPRequest.ValidateAll() if the designated constraints aren't met.

func (CheckHTTPRequestMultiError) AllErrors

func (m CheckHTTPRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CheckHTTPRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CheckHTTPRequestValidationError

type CheckHTTPRequestValidationError struct {
	// contains filtered or unexported fields
}

CheckHTTPRequestValidationError is the validation error returned by CheckHTTPRequest.Validate if the designated constraints aren't met.

func (CheckHTTPRequestValidationError) Cause

Cause function returns cause value.

func (CheckHTTPRequestValidationError) Error

Error satisfies the builtin error interface

func (CheckHTTPRequestValidationError) ErrorName

ErrorName returns error name.

func (CheckHTTPRequestValidationError) Field

Field function returns field value.

func (CheckHTTPRequestValidationError) Key

Key function returns key value.

func (CheckHTTPRequestValidationError) Reason

Reason function returns reason value.

type CheckHTTPRequest_HttpRequest

type CheckHTTPRequest_HttpRequest struct {

	// The HTTP request method, such as `GET`, `POST`.
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// The HTTP request headers.
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// The request target, as it appears in the first line of the HTTP request. This includes
	// the URL path and query-string. No decoding is performed.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// The HTTP request `Host` header value.
	Host string `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	// The HTTP URL scheme, such as `http` and `https`.
	Scheme string `protobuf:"bytes,5,opt,name=scheme,proto3" json:"scheme,omitempty"`
	// The HTTP request size in bytes. If unknown, it must be -1.
	Size int64 `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	// The network protocol used with the request, such as "HTTP/1.0", "HTTP/1.1", or "HTTP/2".
	Protocol string `protobuf:"bytes,7,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// The HTTP request body.
	Body string `protobuf:"bytes,8,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

This message defines attributes for an HTTP request. HTTP/1.x, HTTP/2, gRPC are all considered as HTTP requests.

func CheckHTTPRequest_HttpRequestFromVTPool added in v2.7.0

func CheckHTTPRequest_HttpRequestFromVTPool() *CheckHTTPRequest_HttpRequest

func (*CheckHTTPRequest_HttpRequest) Descriptor deprecated

func (*CheckHTTPRequest_HttpRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckHTTPRequest_HttpRequest.ProtoReflect.Descriptor instead.

func (*CheckHTTPRequest_HttpRequest) GetBody

func (x *CheckHTTPRequest_HttpRequest) GetBody() string

func (*CheckHTTPRequest_HttpRequest) GetHeaders

func (x *CheckHTTPRequest_HttpRequest) GetHeaders() map[string]string

func (*CheckHTTPRequest_HttpRequest) GetHost

func (x *CheckHTTPRequest_HttpRequest) GetHost() string

func (*CheckHTTPRequest_HttpRequest) GetMethod

func (x *CheckHTTPRequest_HttpRequest) GetMethod() string

func (*CheckHTTPRequest_HttpRequest) GetPath

func (x *CheckHTTPRequest_HttpRequest) GetPath() string

func (*CheckHTTPRequest_HttpRequest) GetProtocol

func (x *CheckHTTPRequest_HttpRequest) GetProtocol() string

func (*CheckHTTPRequest_HttpRequest) GetScheme

func (x *CheckHTTPRequest_HttpRequest) GetScheme() string

func (*CheckHTTPRequest_HttpRequest) GetSize

func (x *CheckHTTPRequest_HttpRequest) GetSize() int64

func (*CheckHTTPRequest_HttpRequest) MarshalJSON

func (msg *CheckHTTPRequest_HttpRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CheckHTTPRequest_HttpRequest) MarshalToSizedBufferVT added in v2.7.0

func (m *CheckHTTPRequest_HttpRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckHTTPRequest_HttpRequest) MarshalToVT added in v2.7.0

func (m *CheckHTTPRequest_HttpRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CheckHTTPRequest_HttpRequest) MarshalVT added in v2.7.0

func (m *CheckHTTPRequest_HttpRequest) MarshalVT() (dAtA []byte, err error)

func (*CheckHTTPRequest_HttpRequest) ProtoMessage

func (*CheckHTTPRequest_HttpRequest) ProtoMessage()

func (*CheckHTTPRequest_HttpRequest) ProtoReflect

func (*CheckHTTPRequest_HttpRequest) Reset

func (x *CheckHTTPRequest_HttpRequest) Reset()

func (*CheckHTTPRequest_HttpRequest) ResetVT added in v2.7.0

func (m *CheckHTTPRequest_HttpRequest) ResetVT()

func (*CheckHTTPRequest_HttpRequest) ReturnToVTPool added in v2.7.0

func (m *CheckHTTPRequest_HttpRequest) ReturnToVTPool()

func (*CheckHTTPRequest_HttpRequest) SizeVT added in v2.7.0

func (m *CheckHTTPRequest_HttpRequest) SizeVT() (n int)

func (*CheckHTTPRequest_HttpRequest) String

func (*CheckHTTPRequest_HttpRequest) UnmarshalJSON

func (msg *CheckHTTPRequest_HttpRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*CheckHTTPRequest_HttpRequest) UnmarshalVT added in v2.7.0

func (m *CheckHTTPRequest_HttpRequest) UnmarshalVT(dAtA []byte) error

func (*CheckHTTPRequest_HttpRequest) Validate

func (m *CheckHTTPRequest_HttpRequest) Validate() error

Validate checks the field values on CheckHTTPRequest_HttpRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CheckHTTPRequest_HttpRequest) ValidateAll

func (m *CheckHTTPRequest_HttpRequest) ValidateAll() error

ValidateAll checks the field values on CheckHTTPRequest_HttpRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CheckHTTPRequest_HttpRequestMultiError, or nil if none found.

type CheckHTTPRequest_HttpRequestMultiError

type CheckHTTPRequest_HttpRequestMultiError []error

CheckHTTPRequest_HttpRequestMultiError is an error wrapping multiple validation errors returned by CheckHTTPRequest_HttpRequest.ValidateAll() if the designated constraints aren't met.

func (CheckHTTPRequest_HttpRequestMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (CheckHTTPRequest_HttpRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CheckHTTPRequest_HttpRequestValidationError

type CheckHTTPRequest_HttpRequestValidationError struct {
	// contains filtered or unexported fields
}

CheckHTTPRequest_HttpRequestValidationError is the validation error returned by CheckHTTPRequest_HttpRequest.Validate if the designated constraints aren't met.

func (CheckHTTPRequest_HttpRequestValidationError) Cause

Cause function returns cause value.

func (CheckHTTPRequest_HttpRequestValidationError) Error

Error satisfies the builtin error interface

func (CheckHTTPRequest_HttpRequestValidationError) ErrorName

ErrorName returns error name.

func (CheckHTTPRequest_HttpRequestValidationError) Field

Field function returns field value.

func (CheckHTTPRequest_HttpRequestValidationError) Key

Key function returns key value.

func (CheckHTTPRequest_HttpRequestValidationError) Reason

Reason function returns reason value.

type CheckHTTPResponse

type CheckHTTPResponse struct {

	// Status `OK` allows the request. Any other status indicates the request should be denied
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// An message that contains HTTP response attributes.
	//
	// Types that are assignable to HttpResponse:
	//
	//	*CheckHTTPResponse_DeniedResponse
	//	*CheckHTTPResponse_OkResponse
	HttpResponse isCheckHTTPResponse_HttpResponse `protobuf_oneof:"http_response"`
	// Optional response metadata that will be emitted as dynamic metadata to be consumed by the next
	// filter.
	DynamicMetadata *structpb.Struct `protobuf:"bytes,4,opt,name=dynamic_metadata,json=dynamicMetadata,proto3" json:"dynamic_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckHTTPResponse) Descriptor deprecated

func (*CheckHTTPResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckHTTPResponse.ProtoReflect.Descriptor instead.

func (*CheckHTTPResponse) GetDeniedResponse

func (x *CheckHTTPResponse) GetDeniedResponse() *DeniedHttpResponse

func (*CheckHTTPResponse) GetDynamicMetadata

func (x *CheckHTTPResponse) GetDynamicMetadata() *structpb.Struct

func (*CheckHTTPResponse) GetHttpResponse

func (m *CheckHTTPResponse) GetHttpResponse() isCheckHTTPResponse_HttpResponse

func (*CheckHTTPResponse) GetOkResponse

func (x *CheckHTTPResponse) GetOkResponse() *OkHttpResponse

func (*CheckHTTPResponse) GetStatus

func (x *CheckHTTPResponse) GetStatus() *status.Status

func (*CheckHTTPResponse) MarshalJSON

func (msg *CheckHTTPResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CheckHTTPResponse) MarshalToSizedBufferVT added in v2.7.0

func (m *CheckHTTPResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckHTTPResponse) MarshalToVT added in v2.7.0

func (m *CheckHTTPResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CheckHTTPResponse) MarshalVT added in v2.7.0

func (m *CheckHTTPResponse) MarshalVT() (dAtA []byte, err error)

func (*CheckHTTPResponse) ProtoMessage

func (*CheckHTTPResponse) ProtoMessage()

func (*CheckHTTPResponse) ProtoReflect

func (x *CheckHTTPResponse) ProtoReflect() protoreflect.Message

func (*CheckHTTPResponse) Reset

func (x *CheckHTTPResponse) Reset()

func (*CheckHTTPResponse) SizeVT added in v2.7.0

func (m *CheckHTTPResponse) SizeVT() (n int)

func (*CheckHTTPResponse) String

func (x *CheckHTTPResponse) String() string

func (*CheckHTTPResponse) UnmarshalJSON

func (msg *CheckHTTPResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*CheckHTTPResponse) UnmarshalVT added in v2.7.0

func (m *CheckHTTPResponse) UnmarshalVT(dAtA []byte) error

func (*CheckHTTPResponse) Validate

func (m *CheckHTTPResponse) Validate() error

Validate checks the field values on CheckHTTPResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CheckHTTPResponse) ValidateAll

func (m *CheckHTTPResponse) ValidateAll() error

ValidateAll checks the field values on CheckHTTPResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CheckHTTPResponseMultiError, or nil if none found.

type CheckHTTPResponseMultiError

type CheckHTTPResponseMultiError []error

CheckHTTPResponseMultiError is an error wrapping multiple validation errors returned by CheckHTTPResponse.ValidateAll() if the designated constraints aren't met.

func (CheckHTTPResponseMultiError) AllErrors

func (m CheckHTTPResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CheckHTTPResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CheckHTTPResponseValidationError

type CheckHTTPResponseValidationError struct {
	// contains filtered or unexported fields
}

CheckHTTPResponseValidationError is the validation error returned by CheckHTTPResponse.Validate if the designated constraints aren't met.

func (CheckHTTPResponseValidationError) Cause

Cause function returns cause value.

func (CheckHTTPResponseValidationError) Error

Error satisfies the builtin error interface

func (CheckHTTPResponseValidationError) ErrorName

ErrorName returns error name.

func (CheckHTTPResponseValidationError) Field

Field function returns field value.

func (CheckHTTPResponseValidationError) Key

Key function returns key value.

func (CheckHTTPResponseValidationError) Reason

Reason function returns reason value.

type CheckHTTPResponse_DeniedResponse

type CheckHTTPResponse_DeniedResponse struct {
	// Supplies http attributes for a denied response.
	DeniedResponse *DeniedHttpResponse `protobuf:"bytes,2,opt,name=denied_response,json=deniedResponse,proto3,oneof"`
}

func (*CheckHTTPResponse_DeniedResponse) MarshalToSizedBufferVT added in v2.7.0

func (m *CheckHTTPResponse_DeniedResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckHTTPResponse_DeniedResponse) MarshalToVT added in v2.7.0

func (m *CheckHTTPResponse_DeniedResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CheckHTTPResponse_DeniedResponse) SizeVT added in v2.7.0

func (m *CheckHTTPResponse_DeniedResponse) SizeVT() (n int)

type CheckHTTPResponse_OkResponse

type CheckHTTPResponse_OkResponse struct {
	// Supplies http attributes for an ok response.
	OkResponse *OkHttpResponse `protobuf:"bytes,3,opt,name=ok_response,json=okResponse,proto3,oneof"`
}

func (*CheckHTTPResponse_OkResponse) MarshalToSizedBufferVT added in v2.7.0

func (m *CheckHTTPResponse_OkResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckHTTPResponse_OkResponse) MarshalToVT added in v2.7.0

func (m *CheckHTTPResponse_OkResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CheckHTTPResponse_OkResponse) SizeVT added in v2.7.0

func (m *CheckHTTPResponse_OkResponse) SizeVT() (n int)

type DeniedHttpResponse

type DeniedHttpResponse struct {

	// This field allows the authorization service to send an HTTP response status code to the
	// downstream client. If not set, Envoy sends `403 Forbidden` HTTP status code by default.
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// This field allows the authorization service to send HTTP response headers
	// to the downstream client.
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// This field allows the authorization service to send a response body data
	// to the downstream client.
	Body string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

HTTP attributes for a denied response.

func (*DeniedHttpResponse) Descriptor deprecated

func (*DeniedHttpResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeniedHttpResponse.ProtoReflect.Descriptor instead.

func (*DeniedHttpResponse) GetBody

func (x *DeniedHttpResponse) GetBody() string

func (*DeniedHttpResponse) GetHeaders

func (x *DeniedHttpResponse) GetHeaders() map[string]string

func (*DeniedHttpResponse) GetStatus

func (x *DeniedHttpResponse) GetStatus() int32

func (*DeniedHttpResponse) MarshalJSON

func (msg *DeniedHttpResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*DeniedHttpResponse) MarshalToSizedBufferVT added in v2.7.0

func (m *DeniedHttpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeniedHttpResponse) MarshalToVT added in v2.7.0

func (m *DeniedHttpResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeniedHttpResponse) MarshalVT added in v2.7.0

func (m *DeniedHttpResponse) MarshalVT() (dAtA []byte, err error)

func (*DeniedHttpResponse) ProtoMessage

func (*DeniedHttpResponse) ProtoMessage()

func (*DeniedHttpResponse) ProtoReflect

func (x *DeniedHttpResponse) ProtoReflect() protoreflect.Message

func (*DeniedHttpResponse) Reset

func (x *DeniedHttpResponse) Reset()

func (*DeniedHttpResponse) SizeVT added in v2.7.0

func (m *DeniedHttpResponse) SizeVT() (n int)

func (*DeniedHttpResponse) String

func (x *DeniedHttpResponse) String() string

func (*DeniedHttpResponse) UnmarshalJSON

func (msg *DeniedHttpResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*DeniedHttpResponse) UnmarshalVT added in v2.7.0

func (m *DeniedHttpResponse) UnmarshalVT(dAtA []byte) error

func (*DeniedHttpResponse) Validate

func (m *DeniedHttpResponse) Validate() error

Validate checks the field values on DeniedHttpResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeniedHttpResponse) ValidateAll

func (m *DeniedHttpResponse) ValidateAll() error

ValidateAll checks the field values on DeniedHttpResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeniedHttpResponseMultiError, or nil if none found.

type DeniedHttpResponseMultiError

type DeniedHttpResponseMultiError []error

DeniedHttpResponseMultiError is an error wrapping multiple validation errors returned by DeniedHttpResponse.ValidateAll() if the designated constraints aren't met.

func (DeniedHttpResponseMultiError) AllErrors

func (m DeniedHttpResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeniedHttpResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeniedHttpResponseValidationError

type DeniedHttpResponseValidationError struct {
	// contains filtered or unexported fields
}

DeniedHttpResponseValidationError is the validation error returned by DeniedHttpResponse.Validate if the designated constraints aren't met.

func (DeniedHttpResponseValidationError) Cause

Cause function returns cause value.

func (DeniedHttpResponseValidationError) Error

Error satisfies the builtin error interface

func (DeniedHttpResponseValidationError) ErrorName

ErrorName returns error name.

func (DeniedHttpResponseValidationError) Field

Field function returns field value.

func (DeniedHttpResponseValidationError) Key

Key function returns key value.

func (DeniedHttpResponseValidationError) Reason

Reason function returns reason value.

type FlowControlServiceHTTPClient

type FlowControlServiceHTTPClient interface {
	CheckHTTP(ctx context.Context, in *CheckHTTPRequest, opts ...grpc.CallOption) (*CheckHTTPResponse, error)
}

FlowControlServiceHTTPClient is the client API for FlowControlServiceHTTP service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type FlowControlServiceHTTPServer

type FlowControlServiceHTTPServer interface {
	CheckHTTP(context.Context, *CheckHTTPRequest) (*CheckHTTPResponse, error)
}

FlowControlServiceHTTPServer is the server API for FlowControlServiceHTTP service. All implementations should embed UnimplementedFlowControlServiceHTTPServer for forward compatibility

type OkHttpResponse

type OkHttpResponse struct {

	// HTTP entity headers in addition to the original request headers.
	Headers         map[string]string `` /* 155-byte string literal not displayed */
	DynamicMetadata *structpb.Struct  `protobuf:"bytes,2,opt,name=dynamic_metadata,json=dynamicMetadata,proto3" json:"dynamic_metadata,omitempty"`
	// contains filtered or unexported fields
}

HTTP attributes for an OK response.

func (*OkHttpResponse) Descriptor deprecated

func (*OkHttpResponse) Descriptor() ([]byte, []int)

Deprecated: Use OkHttpResponse.ProtoReflect.Descriptor instead.

func (*OkHttpResponse) GetDynamicMetadata

func (x *OkHttpResponse) GetDynamicMetadata() *structpb.Struct

func (*OkHttpResponse) GetHeaders

func (x *OkHttpResponse) GetHeaders() map[string]string

func (*OkHttpResponse) MarshalJSON

func (msg *OkHttpResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*OkHttpResponse) MarshalToSizedBufferVT added in v2.7.0

func (m *OkHttpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OkHttpResponse) MarshalToVT added in v2.7.0

func (m *OkHttpResponse) MarshalToVT(dAtA []byte) (int, error)

func (*OkHttpResponse) MarshalVT added in v2.7.0

func (m *OkHttpResponse) MarshalVT() (dAtA []byte, err error)

func (*OkHttpResponse) ProtoMessage

func (*OkHttpResponse) ProtoMessage()

func (*OkHttpResponse) ProtoReflect

func (x *OkHttpResponse) ProtoReflect() protoreflect.Message

func (*OkHttpResponse) Reset

func (x *OkHttpResponse) Reset()

func (*OkHttpResponse) SizeVT added in v2.7.0

func (m *OkHttpResponse) SizeVT() (n int)

func (*OkHttpResponse) String

func (x *OkHttpResponse) String() string

func (*OkHttpResponse) UnmarshalJSON

func (msg *OkHttpResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*OkHttpResponse) UnmarshalVT added in v2.7.0

func (m *OkHttpResponse) UnmarshalVT(dAtA []byte) error

func (*OkHttpResponse) Validate

func (m *OkHttpResponse) Validate() error

Validate checks the field values on OkHttpResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*OkHttpResponse) ValidateAll

func (m *OkHttpResponse) ValidateAll() error

ValidateAll checks the field values on OkHttpResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OkHttpResponseMultiError, or nil if none found.

type OkHttpResponseMultiError

type OkHttpResponseMultiError []error

OkHttpResponseMultiError is an error wrapping multiple validation errors returned by OkHttpResponse.ValidateAll() if the designated constraints aren't met.

func (OkHttpResponseMultiError) AllErrors

func (m OkHttpResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OkHttpResponseMultiError) Error

func (m OkHttpResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OkHttpResponseValidationError

type OkHttpResponseValidationError struct {
	// contains filtered or unexported fields
}

OkHttpResponseValidationError is the validation error returned by OkHttpResponse.Validate if the designated constraints aren't met.

func (OkHttpResponseValidationError) Cause

Cause function returns cause value.

func (OkHttpResponseValidationError) Error

Error satisfies the builtin error interface

func (OkHttpResponseValidationError) ErrorName

func (e OkHttpResponseValidationError) ErrorName() string

ErrorName returns error name.

func (OkHttpResponseValidationError) Field

Field function returns field value.

func (OkHttpResponseValidationError) Key

Key function returns key value.

func (OkHttpResponseValidationError) Reason

Reason function returns reason value.

type SocketAddress

type SocketAddress struct {
	Protocol SocketAddress_Protocol `` /* 132-byte string literal not displayed */
	// The address for this socket.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// The port for this socket.
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func SocketAddressFromVTPool added in v2.7.0

func SocketAddressFromVTPool() *SocketAddress

func (*SocketAddress) Descriptor deprecated

func (*SocketAddress) Descriptor() ([]byte, []int)

Deprecated: Use SocketAddress.ProtoReflect.Descriptor instead.

func (*SocketAddress) GetAddress

func (x *SocketAddress) GetAddress() string

func (*SocketAddress) GetPort

func (x *SocketAddress) GetPort() uint32

func (*SocketAddress) GetProtocol

func (x *SocketAddress) GetProtocol() SocketAddress_Protocol

func (*SocketAddress) MarshalJSON

func (msg *SocketAddress) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*SocketAddress) MarshalToSizedBufferVT added in v2.7.0

func (m *SocketAddress) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SocketAddress) MarshalToVT added in v2.7.0

func (m *SocketAddress) MarshalToVT(dAtA []byte) (int, error)

func (*SocketAddress) MarshalVT added in v2.7.0

func (m *SocketAddress) MarshalVT() (dAtA []byte, err error)

func (*SocketAddress) ProtoMessage

func (*SocketAddress) ProtoMessage()

func (*SocketAddress) ProtoReflect

func (x *SocketAddress) ProtoReflect() protoreflect.Message

func (*SocketAddress) Reset

func (x *SocketAddress) Reset()

func (*SocketAddress) ResetVT added in v2.7.0

func (m *SocketAddress) ResetVT()

func (*SocketAddress) ReturnToVTPool added in v2.7.0

func (m *SocketAddress) ReturnToVTPool()

func (*SocketAddress) SizeVT added in v2.7.0

func (m *SocketAddress) SizeVT() (n int)

func (*SocketAddress) String

func (x *SocketAddress) String() string

func (*SocketAddress) UnmarshalJSON

func (msg *SocketAddress) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*SocketAddress) UnmarshalVT added in v2.7.0

func (m *SocketAddress) UnmarshalVT(dAtA []byte) error

func (*SocketAddress) Validate

func (m *SocketAddress) Validate() error

Validate checks the field values on SocketAddress with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SocketAddress) ValidateAll

func (m *SocketAddress) ValidateAll() error

ValidateAll checks the field values on SocketAddress with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SocketAddressMultiError, or nil if none found.

type SocketAddressMultiError

type SocketAddressMultiError []error

SocketAddressMultiError is an error wrapping multiple validation errors returned by SocketAddress.ValidateAll() if the designated constraints aren't met.

func (SocketAddressMultiError) AllErrors

func (m SocketAddressMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SocketAddressMultiError) Error

func (m SocketAddressMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SocketAddressValidationError

type SocketAddressValidationError struct {
	// contains filtered or unexported fields
}

SocketAddressValidationError is the validation error returned by SocketAddress.Validate if the designated constraints aren't met.

func (SocketAddressValidationError) Cause

Cause function returns cause value.

func (SocketAddressValidationError) Error

Error satisfies the builtin error interface

func (SocketAddressValidationError) ErrorName

func (e SocketAddressValidationError) ErrorName() string

ErrorName returns error name.

func (SocketAddressValidationError) Field

Field function returns field value.

func (SocketAddressValidationError) Key

Key function returns key value.

func (SocketAddressValidationError) Reason

Reason function returns reason value.

type SocketAddress_Protocol

type SocketAddress_Protocol int32
const (
	SocketAddress_TCP SocketAddress_Protocol = 0
	SocketAddress_UDP SocketAddress_Protocol = 1
)

func (SocketAddress_Protocol) Descriptor

func (SocketAddress_Protocol) Enum

func (SocketAddress_Protocol) EnumDescriptor deprecated

func (SocketAddress_Protocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use SocketAddress_Protocol.Descriptor instead.

func (SocketAddress_Protocol) Number

func (SocketAddress_Protocol) String

func (x SocketAddress_Protocol) String() string

func (SocketAddress_Protocol) Type

type UnimplementedFlowControlServiceHTTPServer

type UnimplementedFlowControlServiceHTTPServer struct {
}

UnimplementedFlowControlServiceHTTPServer should be embedded to have forward compatible implementations.

func (UnimplementedFlowControlServiceHTTPServer) CheckHTTP

type UnsafeFlowControlServiceHTTPServer

type UnsafeFlowControlServiceHTTPServer interface {
	// contains filtered or unexported methods
}

UnsafeFlowControlServiceHTTPServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FlowControlServiceHTTPServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL