checkhttpv1

package
v2.0.0-...-d8f0e26 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2024 License: Apache-2.0 Imports: 35 Imported by: 5

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"`
	// Expect End denotes whether to expect a FlowEnd call for this flow.
	ExpectEnd bool `protobuf:"varint,6,opt,name=expect_end,json=expectEnd,proto3" json:"expect_end,omitempty"`
	// contains filtered or unexported fields
}

func CheckHTTPRequestFromVTPool 

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) GetExpectEnd 

func (x *CheckHTTPRequest) GetExpectEnd() bool

func (*CheckHTTPRequest) GetRampMode 

func (x *CheckHTTPRequest) GetRampMode() bool

func (*CheckHTTPRequest) GetRequest 

func (x *CheckHTTPRequest) GetRequest() *CheckHTTPRequest_HttpRequest

func (*CheckHTTPRequest) GetSource 

func (x *CheckHTTPRequest) GetSource() *SocketAddress

func (*CheckHTTPRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CheckHTTPRequest) MarshalToSizedBufferVT 

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

func (*CheckHTTPRequest) MarshalToVT 

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

func (*CheckHTTPRequest) MarshalVT 

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 

func (m *CheckHTTPRequest) ResetVT()

func (*CheckHTTPRequest) ReturnToVTPool 

func (m *CheckHTTPRequest) ReturnToVTPool()

func (*CheckHTTPRequest) SizeVT 

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 

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 

func (m CheckHTTPRequestMultiError) Error() string

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 

func (e CheckHTTPRequestValidationError) Cause() error

Cause function returns cause value.

func (CheckHTTPRequestValidationError) Error 

func (e CheckHTTPRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CheckHTTPRequestValidationError) ErrorName 

func (e CheckHTTPRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CheckHTTPRequestValidationError) Field 

func (e CheckHTTPRequestValidationError) Field() string

Field function returns field value.

func (CheckHTTPRequestValidationError) Key 

func (e CheckHTTPRequestValidationError) Key() bool

Key function returns key value.

func (CheckHTTPRequestValidationError) Reason 

func (e CheckHTTPRequestValidationError) Reason() string

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 

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 

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

func (*CheckHTTPRequest_HttpRequest) MarshalToVT 

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

func (*CheckHTTPRequest_HttpRequest) MarshalVT 

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

func (*CheckHTTPRequest_HttpRequest) ProtoMessage 

func (*CheckHTTPRequest_HttpRequest) ProtoMessage()

func (*CheckHTTPRequest_HttpRequest) ProtoReflect 

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

func (*CheckHTTPRequest_HttpRequest) Reset 

func (x *CheckHTTPRequest_HttpRequest) Reset()

func (*CheckHTTPRequest_HttpRequest) ResetVT 

func (m *CheckHTTPRequest_HttpRequest) ResetVT()

func (*CheckHTTPRequest_HttpRequest) ReturnToVTPool 

func (m *CheckHTTPRequest_HttpRequest) ReturnToVTPool()

func (*CheckHTTPRequest_HttpRequest) SizeVT 

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

func (*CheckHTTPRequest_HttpRequest) String 

func (x *CheckHTTPRequest_HttpRequest) String() string

func (*CheckHTTPRequest_HttpRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CheckHTTPRequest_HttpRequest) UnmarshalVT 

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 

func (m CheckHTTPRequest_HttpRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CheckHTTPRequest_HttpRequestMultiError) Error 

func (m CheckHTTPRequest_HttpRequestMultiError) Error() string

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 

func (e CheckHTTPRequest_HttpRequestValidationError) Cause() error

Cause function returns cause value.

func (CheckHTTPRequest_HttpRequestValidationError) Error 

func (e CheckHTTPRequest_HttpRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CheckHTTPRequest_HttpRequestValidationError) ErrorName 

func (e CheckHTTPRequest_HttpRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CheckHTTPRequest_HttpRequestValidationError) Field 

func (e CheckHTTPRequest_HttpRequestValidationError) Field() string

Field function returns field value.

func (CheckHTTPRequest_HttpRequestValidationError) Key 

func (e CheckHTTPRequest_HttpRequestValidationError) Key() bool

Key function returns key value.

func (CheckHTTPRequest_HttpRequestValidationError) Reason 

func (e CheckHTTPRequest_HttpRequestValidationError) Reason() string

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"`
	// The response from the check call.
	CheckResponse *v1.CheckResponse `protobuf:"bytes,5,opt,name=check_response,json=checkResponse,proto3" json:"check_response,omitempty"`
	// 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) GetCheckResponse 

func (x *CheckHTTPResponse) GetCheckResponse() *v1.CheckResponse

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 

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

func (*CheckHTTPResponse) MarshalToVT 

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

func (*CheckHTTPResponse) MarshalVT 

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 

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 

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 

func (m CheckHTTPResponseMultiError) Error() string

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 

func (e CheckHTTPResponseValidationError) Cause() error

Cause function returns cause value.

func (CheckHTTPResponseValidationError) Error 

func (e CheckHTTPResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CheckHTTPResponseValidationError) ErrorName 

func (e CheckHTTPResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CheckHTTPResponseValidationError) Field 

func (e CheckHTTPResponseValidationError) Field() string

Field function returns field value.

func (CheckHTTPResponseValidationError) Key 

func (e CheckHTTPResponseValidationError) Key() bool

Key function returns key value.

func (CheckHTTPResponseValidationError) Reason 

func (e CheckHTTPResponseValidationError) Reason() string

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 

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

func (*CheckHTTPResponse_DeniedResponse) MarshalToVT 

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

func (*CheckHTTPResponse_DeniedResponse) SizeVT 

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 

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

func (*CheckHTTPResponse_OkResponse) MarshalToVT 

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

func (*CheckHTTPResponse_OkResponse) SizeVT 

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 

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

func (*DeniedHttpResponse) MarshalToVT 

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

func (*DeniedHttpResponse) MarshalVT 

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 

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 

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 

func (m DeniedHttpResponseMultiError) Error() string

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 

func (e DeniedHttpResponseValidationError) Cause() error

Cause function returns cause value.

func (DeniedHttpResponseValidationError) Error 

func (e DeniedHttpResponseValidationError) Error() string

Error satisfies the builtin error interface

func (DeniedHttpResponseValidationError) ErrorName 

func (e DeniedHttpResponseValidationError) ErrorName() string

ErrorName returns error name.

func (DeniedHttpResponseValidationError) Field 

func (e DeniedHttpResponseValidationError) Field() string

Field function returns field value.

func (DeniedHttpResponseValidationError) Key 

func (e DeniedHttpResponseValidationError) Key() bool

Key function returns key value.

func (DeniedHttpResponseValidationError) Reason 

func (e DeniedHttpResponseValidationError) Reason() string

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.

func NewFlowControlServiceHTTPClient 

func NewFlowControlServiceHTTPClient(cc grpc.ClientConnInterface) FlowControlServiceHTTPClient

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 

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

func (*OkHttpResponse) MarshalToVT 

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

func (*OkHttpResponse) MarshalVT 

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 

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 

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 

func (e OkHttpResponseValidationError) Cause() error

Cause function returns cause value.

func (OkHttpResponseValidationError) Error 

func (e OkHttpResponseValidationError) Error() string

Error satisfies the builtin error interface

func (OkHttpResponseValidationError) ErrorName 

func (e OkHttpResponseValidationError) ErrorName() string

ErrorName returns error name.

func (OkHttpResponseValidationError) Field 

func (e OkHttpResponseValidationError) Field() string

Field function returns field value.

func (OkHttpResponseValidationError) Key 

func (e OkHttpResponseValidationError) Key() bool

Key function returns key value.

func (OkHttpResponseValidationError) Reason 

func (e OkHttpResponseValidationError) Reason() string

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 

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 

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

func (*SocketAddress) MarshalToVT 

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

func (*SocketAddress) MarshalVT 

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 

func (m *SocketAddress) ResetVT()

func (*SocketAddress) ReturnToVTPool 

func (m *SocketAddress) ReturnToVTPool()

func (*SocketAddress) SizeVT 

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 

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 

func (e SocketAddressValidationError) Cause() error

Cause function returns cause value.

func (SocketAddressValidationError) Error 

func (e SocketAddressValidationError) Error() string

Error satisfies the builtin error interface

func (SocketAddressValidationError) ErrorName 

func (e SocketAddressValidationError) ErrorName() string

ErrorName returns error name.

func (SocketAddressValidationError) Field 

func (e SocketAddressValidationError) Field() string

Field function returns field value.

func (SocketAddressValidationError) Key 

func (e SocketAddressValidationError) Key() bool

Key function returns key value.

func (SocketAddressValidationError) Reason 

func (e SocketAddressValidationError) Reason() string

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) Descriptor() protoreflect.EnumDescriptor

func (SocketAddress_Protocol) Enum 

func (x SocketAddress_Protocol) Enum() *SocketAddress_Protocol

func (SocketAddress_Protocol) EnumDescriptor deprecated 

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

Deprecated: Use SocketAddress_Protocol.Descriptor instead.

func (SocketAddress_Protocol) Number 

func (x SocketAddress_Protocol) Number() protoreflect.EnumNumber

func (SocketAddress_Protocol) String 

func (x SocketAddress_Protocol) String() string

func (SocketAddress_Protocol) Type 

func (SocketAddress_Protocol) Type() protoreflect.EnumType

type UnimplementedFlowControlServiceHTTPServer 

type UnimplementedFlowControlServiceHTTPServer struct {
}

UnimplementedFlowControlServiceHTTPServer should be embedded to have forward compatible implementations.

func (UnimplementedFlowControlServiceHTTPServer) CheckHTTP 

func (UnimplementedFlowControlServiceHTTPServer) CheckHTTP(context.Context, *CheckHTTPRequest) (*CheckHTTPResponse, error)

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.