correlation

package
v1.1.80 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 10 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CorrelationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "amplify.agent.correlation.CorrelationService",
	HandlerType: (*CorrelationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetResourceContext",
			Handler:    _CorrelationService_GetResourceContext_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "correlation/correlation.proto",
}

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

View Source 
var File_correlation_correlation_proto protoreflect.FileDescriptor

Functions

func RegisterCorrelationServiceServer 

func RegisterCorrelationServiceServer(s grpc.ServiceRegistrar, srv CorrelationServiceServer)

Types

type CorrelationServiceClient 

type CorrelationServiceClient interface {
	GetResourceContext(ctx context.Context, in *TransactionContext, opts ...grpc.CallOption) (*ResourceContext, error)
}

CorrelationServiceClient is the client API for CorrelationService 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 NewCorrelationServiceClient 

func NewCorrelationServiceClient(cc grpc.ClientConnInterface) CorrelationServiceClient

type CorrelationServiceServer 

type CorrelationServiceServer interface {
	GetResourceContext(context.Context, *TransactionContext) (*ResourceContext, error)
	// contains filtered or unexported methods
}

CorrelationServiceServer is the server API for CorrelationService service. All implementations must embed UnimplementedCorrelationServiceServer for forward compatibility

type Request 

type Request struct {

	// HTTP request method
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// The request protocol scheme
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// The request protocol scheme version
	ProtocolVersion string `protobuf:"bytes,3,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// The value of Authority/Host request header
	Authority string `protobuf:"bytes,4,opt,name=authority,proto3" json:"authority,omitempty"`
	// The port of incoming request
	Port uint32 `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// The request URI
	Path string `protobuf:"bytes,6,opt,name=path,proto3" json:"path,omitempty"`
	// The request URI as received by dataplane gateway
	OriginalPath string `protobuf:"bytes,7,opt,name=original_path,json=originalPath,proto3" json:"original_path,omitempty"`
	// The value of User-Agent request header
	UserAgent string `protobuf:"bytes,8,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"`
	// The value of Referer request header
	Referer string `protobuf:"bytes,9,opt,name=referer,proto3" json:"referer,omitempty"`
	// The value of X-Forwarded-For request header
	ForwardedFor string `protobuf:"bytes,10,opt,name=forwarded_for,json=forwardedFor,proto3" json:"forwarded_for,omitempty"`
	// The map of request headers
	Headers map[string]string `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request - represents the API request properties

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetAuthority 

func (x *Request) GetAuthority() string

func (*Request) GetForwardedFor 

func (x *Request) GetForwardedFor() string

func (*Request) GetHeaders 

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

func (*Request) GetMethod 

func (x *Request) GetMethod() string

func (*Request) GetOriginalPath 

func (x *Request) GetOriginalPath() string

func (*Request) GetPath 

func (x *Request) GetPath() string

func (*Request) GetPort 

func (x *Request) GetPort() uint32

func (*Request) GetProtocol 

func (x *Request) GetProtocol() string

func (*Request) GetProtocolVersion 

func (x *Request) GetProtocolVersion() string

func (*Request) GetReferer 

func (x *Request) GetReferer() string

func (*Request) GetUserAgent 

func (x *Request) GetUserAgent() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type ResourceContext 

type ResourceContext struct {

	// The dataplane gateway specific identifier used for correlating
	// the API service resource
	ApiId string `protobuf:"bytes,1,opt,name=api_id,json=apiId,proto3" json:"api_id,omitempty"`
	// The dataplane gateway specific deployment stage name used for
	// correlating the API service resource
	Stage string `protobuf:"bytes,2,opt,name=stage,proto3" json:"stage,omitempty"`
	// The dataplane gateway specific version identifier used for
	// correlating the API service resource
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// The dataplane gateway specific identifier used for correlating
	// the Amplify marketplace subscription/application
	ConsumerId string `protobuf:"bytes,4,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	// contains filtered or unexported fields
}

ResourceContext - holds the properties that correlates the transaction with Amplify API resources.

func (*ResourceContext) Descriptor deprecated 

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

Deprecated: Use ResourceContext.ProtoReflect.Descriptor instead.

func (*ResourceContext) GetApiId 

func (x *ResourceContext) GetApiId() string

func (*ResourceContext) GetConsumerId 

func (x *ResourceContext) GetConsumerId() string

func (*ResourceContext) GetStage 

func (x *ResourceContext) GetStage() string

func (*ResourceContext) GetVersion 

func (x *ResourceContext) GetVersion() string

func (*ResourceContext) ProtoMessage 

func (*ResourceContext) ProtoMessage()

func (*ResourceContext) ProtoReflect 

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

func (*ResourceContext) Reset 

func (x *ResourceContext) Reset()

func (*ResourceContext) String 

func (x *ResourceContext) String() string

type Response 

type Response struct {

	// The HTTP response code
	ResponseCode uint32 `protobuf:"varint,1,opt,name=response_code,json=responseCode,proto3" json:"response_code,omitempty"`
	// The map of response headers
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Response - represents the API response properties

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetHeaders 

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

func (*Response) GetResponseCode 

func (x *Response) GetResponseCode() uint32

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type TransactionContext 

type TransactionContext struct {

	// The request/transaction identifier
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// The source address on which the request from the user was received
	OriginAddress string `protobuf:"bytes,2,opt,name=originAddress,proto3" json:"originAddress,omitempty"`
	// The alias name for the source address
	OriginAlias string `protobuf:"bytes,3,opt,name=originAlias,proto3" json:"originAlias,omitempty"`
	// The destination address on which the request from the user was received
	DestinationAddress string `protobuf:"bytes,4,opt,name=destinationAddress,proto3" json:"destinationAddress,omitempty"`
	// The alias name for the destination address
	DestinationAlias string `protobuf:"bytes,5,opt,name=destinationAlias,proto3" json:"destinationAlias,omitempty"`
	// The name of the routing rule defined for dataplane gateway
	RouteName string `protobuf:"bytes,6,opt,name=routeName,proto3" json:"routeName,omitempty"`
	// The map of additional metadata associated to the traffic
	// for specific dataplane gateway
	Metadata map[string]*structpb.Value `` /* 157-byte string literal not displayed */
	// The response properties associated with the API transaction
	Request *Request `protobuf:"bytes,8,opt,name=request,proto3" json:"request,omitempty"`
	// The response properties associated with the API transaction
	Response *Response `protobuf:"bytes,9,opt,name=response,proto3" json:"response,omitempty"`
	// The time request was received by the dataplane gateway
	StartTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

TransactionContext - represents the API traffic transaction context

func (*TransactionContext) Descriptor deprecated 

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

Deprecated: Use TransactionContext.ProtoReflect.Descriptor instead.

func (*TransactionContext) GetDestinationAddress 

func (x *TransactionContext) GetDestinationAddress() string

func (*TransactionContext) GetDestinationAlias 

func (x *TransactionContext) GetDestinationAlias() string

func (*TransactionContext) GetMetadata 

func (x *TransactionContext) GetMetadata() map[string]*structpb.Value

func (*TransactionContext) GetOriginAddress 

func (x *TransactionContext) GetOriginAddress() string

func (*TransactionContext) GetOriginAlias 

func (x *TransactionContext) GetOriginAlias() string

func (*TransactionContext) GetRequest 

func (x *TransactionContext) GetRequest() *Request

func (*TransactionContext) GetResponse 

func (x *TransactionContext) GetResponse() *Response

func (*TransactionContext) GetRouteName 

func (x *TransactionContext) GetRouteName() string

func (*TransactionContext) GetStartTime 

func (x *TransactionContext) GetStartTime() *timestamppb.Timestamp

func (*TransactionContext) GetTransactionId 

func (x *TransactionContext) GetTransactionId() string

func (*TransactionContext) ProtoMessage 

func (*TransactionContext) ProtoMessage()

func (*TransactionContext) ProtoReflect 

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

func (*TransactionContext) Reset 

func (x *TransactionContext) Reset()

func (*TransactionContext) String 

func (x *TransactionContext) String() string

type UnimplementedCorrelationServiceServer 

type UnimplementedCorrelationServiceServer struct {
}

UnimplementedCorrelationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCorrelationServiceServer) GetResourceContext 

func (UnimplementedCorrelationServiceServer) GetResourceContext(context.Context, *TransactionContext) (*ResourceContext, error)

type UnsafeCorrelationServiceServer 

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

UnsafeCorrelationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CorrelationServiceServer 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.