apigeeconnectpb

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2024 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "OPEN_NEW_STREAM",
	}
	Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"OPEN_NEW_STREAM":    1,
	}
)

Enum value maps for Action.

View Source 
var (
	TetherEndpoint_name = map[int32]string{
		0: "TETHER_ENDPOINT_UNSPECIFIED",
		1: "APIGEE_MART",
		2: "APIGEE_RUNTIME",
		3: "APIGEE_MINT_RATING",
	}
	TetherEndpoint_value = map[string]int32{
		"TETHER_ENDPOINT_UNSPECIFIED": 0,
		"APIGEE_MART":                 1,
		"APIGEE_RUNTIME":              2,
		"APIGEE_MINT_RATING":          3,
	}
)

Enum value maps for TetherEndpoint.

View Source 
var (
	Scheme_name = map[int32]string{
		0: "SCHEME_UNSPECIFIED",
		1: "HTTPS",
	}
	Scheme_value = map[string]int32{
		"SCHEME_UNSPECIFIED": 0,
		"HTTPS":              1,
	}
)

Enum value maps for Scheme.

View Source 
var File_google_cloud_apigeeconnect_v1_connection_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_apigeeconnect_v1_tether_proto protoreflect.FileDescriptor

Functions

func RegisterConnectionServiceServer 

func RegisterConnectionServiceServer(s *grpc.Server, srv ConnectionServiceServer)

func RegisterTetherServer 

func RegisterTetherServer(s *grpc.Server, srv TetherServer)

Types

type Action 

type Action int32

The action taken by agent. 

const (
	// Unspecified Action.
	Action_ACTION_UNSPECIFIED Action = 0
	// Indicates that agent should open a new stream.
	Action_OPEN_NEW_STREAM Action = 1
)

func (Action) Descriptor 

func (Action) Descriptor() protoreflect.EnumDescriptor

func (Action) Enum 

func (x Action) Enum() *Action

func (Action) EnumDescriptor deprecated 

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

Deprecated: Use Action.Descriptor instead.

func (Action) Number 

func (x Action) Number() protoreflect.EnumNumber

func (Action) String 

func (x Action) String() string

func (Action) Type 

func (Action) Type() protoreflect.EnumType

type Cluster 

type Cluster struct {

	// The name of the cluster.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The region of the cluster.
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetRegion 

func (x *Cluster) GetRegion() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type Connection 

type Connection struct {

	// The endpoint that the connection is made against.
	// Format: `projects/{project_number}/endpoints/{endpoint}`
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Cluster information.
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// The count of streams.
	StreamCount int32 `protobuf:"varint,3,opt,name=stream_count,json=streamCount,proto3" json:"stream_count,omitempty"`
	// contains filtered or unexported fields
}

func (*Connection) Descriptor deprecated 

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

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetCluster 

func (x *Connection) GetCluster() *Cluster

func (*Connection) GetEndpoint 

func (x *Connection) GetEndpoint() string

func (*Connection) GetStreamCount 

func (x *Connection) GetStreamCount() int32

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect 

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

func (*Connection) Reset 

func (x *Connection) Reset()

func (*Connection) String 

func (x *Connection) String() string

type ConnectionServiceClient 

type ConnectionServiceClient interface {
	// Lists connections that are currently active for the given Apigee Connect
	// endpoint.
	ListConnections(ctx context.Context, in *ListConnectionsRequest, opts ...grpc.CallOption) (*ListConnectionsResponse, error)
}

ConnectionServiceClient is the client API for ConnectionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewConnectionServiceClient 

func NewConnectionServiceClient(cc grpc.ClientConnInterface) ConnectionServiceClient

type ConnectionServiceServer 

type ConnectionServiceServer interface {
	// Lists connections that are currently active for the given Apigee Connect
	// endpoint.
	ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)
}

ConnectionServiceServer is the server API for ConnectionService service.

type EgressRequest 

type EgressRequest struct {

	// Unique identifier for the request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Actual payload to send to agent.
	Payload *Payload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Tether Endpoint.
	Endpoint TetherEndpoint `protobuf:"varint,3,opt,name=endpoint,proto3,enum=google.cloud.apigeeconnect.v1.TetherEndpoint" json:"endpoint,omitempty"`
	// GCP Project.
	// Format: `projects/{project_number}`.
	Project string `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	// Unique identifier for clients to trace their request/response.
	TraceId string `protobuf:"bytes,5,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// Timeout for the HTTP request.
	Timeout *durationpb.Duration `protobuf:"bytes,6,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

gRPC request payload for tether.

func (*EgressRequest) Descriptor deprecated 

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

Deprecated: Use EgressRequest.ProtoReflect.Descriptor instead.

func (*EgressRequest) GetEndpoint 

func (x *EgressRequest) GetEndpoint() TetherEndpoint

func (*EgressRequest) GetId 

func (x *EgressRequest) GetId() string

func (*EgressRequest) GetPayload 

func (x *EgressRequest) GetPayload() *Payload

func (*EgressRequest) GetProject 

func (x *EgressRequest) GetProject() string

func (*EgressRequest) GetTimeout 

func (x *EgressRequest) GetTimeout() *durationpb.Duration

func (*EgressRequest) GetTraceId 

func (x *EgressRequest) GetTraceId() string

func (*EgressRequest) ProtoMessage 

func (*EgressRequest) ProtoMessage()

func (*EgressRequest) ProtoReflect 

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

func (*EgressRequest) Reset 

func (x *EgressRequest) Reset()

func (*EgressRequest) String 

func (x *EgressRequest) String() string

type EgressResponse 

type EgressResponse struct {

	// Unique identifier for the response. Matches the EgressRequest's id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// HttpResponse.
	HttpResponse *HttpResponse `protobuf:"bytes,2,opt,name=http_response,json=httpResponse,proto3" json:"http_response,omitempty"`
	// Errors from application when handling the http request.
	Status *status.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// GCP Project.
	// Format: `projects/{project_number}`.
	Project string `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	// Unique identifier for clients to trace their request/response. Matches the
	// EgressRequest's trace id
	TraceId string `protobuf:"bytes,5,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// Tether Endpoint.
	Endpoint TetherEndpoint `protobuf:"varint,6,opt,name=endpoint,proto3,enum=google.cloud.apigeeconnect.v1.TetherEndpoint" json:"endpoint,omitempty"`
	// Name is the full resource path of endpoint.
	// Format: `projects/{project_number or project_id}/endpoints/{endpoint}`
	Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

gRPC response payload for tether.

func (*EgressResponse) Descriptor deprecated 

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

Deprecated: Use EgressResponse.ProtoReflect.Descriptor instead.

func (*EgressResponse) GetEndpoint 

func (x *EgressResponse) GetEndpoint() TetherEndpoint

func (*EgressResponse) GetHttpResponse 

func (x *EgressResponse) GetHttpResponse() *HttpResponse

func (*EgressResponse) GetId 

func (x *EgressResponse) GetId() string

func (*EgressResponse) GetName 

func (x *EgressResponse) GetName() string

func (*EgressResponse) GetProject 

func (x *EgressResponse) GetProject() string

func (*EgressResponse) GetStatus 

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

func (*EgressResponse) GetTraceId 

func (x *EgressResponse) GetTraceId() string

func (*EgressResponse) ProtoMessage 

func (*EgressResponse) ProtoMessage()

func (*EgressResponse) ProtoReflect 

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

func (*EgressResponse) Reset 

func (x *EgressResponse) Reset()

func (*EgressResponse) String 

func (x *EgressResponse) String() string
type Header struct {
	Key    string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

The http headers.

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetKey 

func (x *Header) GetKey() string

func (*Header) GetValues 

func (x *Header) GetValues() []string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type HttpRequest 

type HttpRequest struct {

	// A unique identifier for the request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The HTTP request method.
	// Valid methods: "GET", "HEAD", "POST", "PUT", "PATCH","DELETE".
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// The HTTP request URL.
	Url *Url `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// The HTTP request headers.
	Headers []*Header `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
	// HTTP request body.
	Body []byte `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

The proto definition of http request.

func (*HttpRequest) Descriptor deprecated 

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

Deprecated: Use HttpRequest.ProtoReflect.Descriptor instead.

func (*HttpRequest) GetBody 

func (x *HttpRequest) GetBody() []byte

func (*HttpRequest) GetHeaders 

func (x *HttpRequest) GetHeaders() []*Header

func (*HttpRequest) GetId 

func (x *HttpRequest) GetId() string

func (*HttpRequest) GetMethod 

func (x *HttpRequest) GetMethod() string

func (*HttpRequest) GetUrl 

func (x *HttpRequest) GetUrl() *Url

func (*HttpRequest) ProtoMessage 

func (*HttpRequest) ProtoMessage()

func (*HttpRequest) ProtoReflect 

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

func (*HttpRequest) Reset 

func (x *HttpRequest) Reset()

func (*HttpRequest) String 

func (x *HttpRequest) String() string

type HttpResponse 

type HttpResponse struct {

	// A unique identifier that matches the request ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Status of http response, e.g. "200 OK".
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Status code of http response, e.g. 200.
	StatusCode int32 `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// The HTTP 1.1 response body.
	Body []byte `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// The HTTP response headers.
	Headers []*Header `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	// Content length records the length of the associated content. The
	// value -1 indicates that the length is unknown. Unless http method
	// is "HEAD", values >= 0 indicate that the given number of bytes may
	// be read from Body.
	ContentLength int64 `protobuf:"varint,6,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	// contains filtered or unexported fields
}

The proto definition of http response.

func (*HttpResponse) Descriptor deprecated 

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

Deprecated: Use HttpResponse.ProtoReflect.Descriptor instead.

func (*HttpResponse) GetBody 

func (x *HttpResponse) GetBody() []byte

func (*HttpResponse) GetContentLength 

func (x *HttpResponse) GetContentLength() int64

func (*HttpResponse) GetHeaders 

func (x *HttpResponse) GetHeaders() []*Header

func (*HttpResponse) GetId 

func (x *HttpResponse) GetId() string

func (*HttpResponse) GetStatus 

func (x *HttpResponse) GetStatus() string

func (*HttpResponse) GetStatusCode 

func (x *HttpResponse) GetStatusCode() int32

func (*HttpResponse) ProtoMessage 

func (*HttpResponse) ProtoMessage()

func (*HttpResponse) ProtoReflect 

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

func (*HttpResponse) Reset 

func (x *HttpResponse) Reset()

func (*HttpResponse) String 

func (x *HttpResponse) String() string

type ListConnectionsRequest 

type ListConnectionsRequest struct {

	// Required. Parent name of the form:
	//
	//	`projects/{project_number or project_id}/endpoints/{endpoint}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of connections to return. The service may return fewer
	// than this value. If unspecified, at most 100 connections will be returned.
	// The maximum value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListConnections` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListConnections` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

The request for [ListConnections][Management.ListConnections].

func (*ListConnectionsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectionsRequest) GetPageSize 

func (x *ListConnectionsRequest) GetPageSize() int32

func (*ListConnectionsRequest) GetPageToken 

func (x *ListConnectionsRequest) GetPageToken() string

func (*ListConnectionsRequest) GetParent 

func (x *ListConnectionsRequest) GetParent() string

func (*ListConnectionsRequest) ProtoMessage 

func (*ListConnectionsRequest) ProtoMessage()

func (*ListConnectionsRequest) ProtoReflect 

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

func (*ListConnectionsRequest) Reset 

func (x *ListConnectionsRequest) Reset()

func (*ListConnectionsRequest) String 

func (x *ListConnectionsRequest) String() string

type ListConnectionsResponse 

type ListConnectionsResponse struct {

	// A list of clients.
	Connections []*Connection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

The response for [ListConnections][Management.ListConnections].

func (*ListConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectionsResponse) GetConnections 

func (x *ListConnectionsResponse) GetConnections() []*Connection

func (*ListConnectionsResponse) GetNextPageToken 

func (x *ListConnectionsResponse) GetNextPageToken() string

func (*ListConnectionsResponse) ProtoMessage 

func (*ListConnectionsResponse) ProtoMessage()

func (*ListConnectionsResponse) ProtoReflect 

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

func (*ListConnectionsResponse) Reset 

func (x *ListConnectionsResponse) Reset()

func (*ListConnectionsResponse) String 

func (x *ListConnectionsResponse) String() string

type Payload 

type Payload struct {

	// The kind of payload.
	//
	// Types that are assignable to Kind:
	//
	//	*Payload_HttpRequest
	//	*Payload_StreamInfo
	//	*Payload_Action
	Kind isPayload_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

Payload for EgressRequest.

func (*Payload) Descriptor deprecated 

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetAction 

func (x *Payload) GetAction() Action

func (*Payload) GetHttpRequest 

func (x *Payload) GetHttpRequest() *HttpRequest

func (*Payload) GetKind 

func (m *Payload) GetKind() isPayload_Kind

func (*Payload) GetStreamInfo 

func (x *Payload) GetStreamInfo() *StreamInfo

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect 

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

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) String 

func (x *Payload) String() string

type Payload_Action 

type Payload_Action struct {
	// The action taken by agent.
	Action Action `protobuf:"varint,3,opt,name=action,proto3,enum=google.cloud.apigeeconnect.v1.Action,oneof"`
}

type Payload_HttpRequest 

type Payload_HttpRequest struct {
	// The HttpRequest proto.
	HttpRequest *HttpRequest `protobuf:"bytes,1,opt,name=http_request,json=httpRequest,proto3,oneof"`
}

type Payload_StreamInfo 

type Payload_StreamInfo struct {
	// The information of stream.
	StreamInfo *StreamInfo `protobuf:"bytes,2,opt,name=stream_info,json=streamInfo,proto3,oneof"`
}

type Scheme 

type Scheme int32

HTTP Scheme. 

const (
	// Unspecified scheme.
	Scheme_SCHEME_UNSPECIFIED Scheme = 0
	// HTTPS protocol.
	Scheme_HTTPS Scheme = 1
)

func (Scheme) Descriptor 

func (Scheme) Descriptor() protoreflect.EnumDescriptor

func (Scheme) Enum 

func (x Scheme) Enum() *Scheme

func (Scheme) EnumDescriptor deprecated 

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

Deprecated: Use Scheme.Descriptor instead.

func (Scheme) Number 

func (x Scheme) Number() protoreflect.EnumNumber

func (Scheme) String 

func (x Scheme) String() string

func (Scheme) Type 

func (Scheme) Type() protoreflect.EnumType

type StreamInfo 

type StreamInfo struct {

	// Unique identifier for the stream.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

The Information of bi-directional stream.

func (*StreamInfo) Descriptor deprecated 

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

Deprecated: Use StreamInfo.ProtoReflect.Descriptor instead.

func (*StreamInfo) GetId 

func (x *StreamInfo) GetId() string

func (*StreamInfo) ProtoMessage 

func (*StreamInfo) ProtoMessage()

func (*StreamInfo) ProtoReflect 

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

func (*StreamInfo) Reset 

func (x *StreamInfo) Reset()

func (*StreamInfo) String 

func (x *StreamInfo) String() string

type TetherClient 

type TetherClient interface {
	// Egress streams egress requests and responses. Logically, this is not
	// actually a streaming request, but uses streaming as a mechanism to flip
	// the client-server relationship of gRPC so that the server can act as a
	// client.
	// The listener, the RPC server, accepts connections from the dialer,
	// the RPC client.
	// The listener streams http requests and the dialer streams http responses.
	Egress(ctx context.Context, opts ...grpc.CallOption) (Tether_EgressClient, error)
}

TetherClient is the client API for Tether service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTetherClient 

func NewTetherClient(cc grpc.ClientConnInterface) TetherClient

type TetherEndpoint 

type TetherEndpoint int32

Endpoint indicates where the messages will be delivered. 

const (
	// Unspecified tether endpoint.
	TetherEndpoint_TETHER_ENDPOINT_UNSPECIFIED TetherEndpoint = 0
	// Apigee MART endpoint.
	TetherEndpoint_APIGEE_MART TetherEndpoint = 1
	// Apigee Runtime endpoint.
	TetherEndpoint_APIGEE_RUNTIME TetherEndpoint = 2
	// Apigee Mint Rating endpoint.
	TetherEndpoint_APIGEE_MINT_RATING TetherEndpoint = 3
)

func (TetherEndpoint) Descriptor 

func (TetherEndpoint) Descriptor() protoreflect.EnumDescriptor

func (TetherEndpoint) Enum 

func (x TetherEndpoint) Enum() *TetherEndpoint

func (TetherEndpoint) EnumDescriptor deprecated 

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

Deprecated: Use TetherEndpoint.Descriptor instead.

func (TetherEndpoint) Number 

func (x TetherEndpoint) Number() protoreflect.EnumNumber

func (TetherEndpoint) String 

func (x TetherEndpoint) String() string

func (TetherEndpoint) Type 

func (TetherEndpoint) Type() protoreflect.EnumType

type TetherServer 

type TetherServer interface {
	// Egress streams egress requests and responses. Logically, this is not
	// actually a streaming request, but uses streaming as a mechanism to flip
	// the client-server relationship of gRPC so that the server can act as a
	// client.
	// The listener, the RPC server, accepts connections from the dialer,
	// the RPC client.
	// The listener streams http requests and the dialer streams http responses.
	Egress(Tether_EgressServer) error
}

TetherServer is the server API for Tether service.

type Tether_EgressClient 

type Tether_EgressClient interface {
	Send(*EgressResponse) error
	Recv() (*EgressRequest, error)
	grpc.ClientStream
}

type Tether_EgressServer 

type Tether_EgressServer interface {
	Send(*EgressRequest) error
	Recv() (*EgressResponse, error)
	grpc.ServerStream
}

type UnimplementedConnectionServiceServer 

type UnimplementedConnectionServiceServer struct {
}

UnimplementedConnectionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedConnectionServiceServer) ListConnections 

func (*UnimplementedConnectionServiceServer) ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)

type UnimplementedTetherServer 

type UnimplementedTetherServer struct {
}

UnimplementedTetherServer can be embedded to have forward compatible implementations.

func (*UnimplementedTetherServer) Egress 

func (*UnimplementedTetherServer) Egress(Tether_EgressServer) error

type Url 

type Url struct {

	// Scheme.
	Scheme Scheme `protobuf:"varint,1,opt,name=scheme,proto3,enum=google.cloud.apigeeconnect.v1.Scheme" json:"scheme,omitempty"`
	// Host or Host:Port.
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// Path starts with `/`.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

The proto definition of url. A url represents a URL and the general form represented is: 

`[scheme://][google.cloud.apigeeconnect.v1.Url.host][path]`

func (*Url) Descriptor deprecated 

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

Deprecated: Use Url.ProtoReflect.Descriptor instead.

func (*Url) GetHost 

func (x *Url) GetHost() string

func (*Url) GetPath 

func (x *Url) GetPath() string

func (*Url) GetScheme 

func (x *Url) GetScheme() Scheme

func (*Url) ProtoMessage 

func (*Url) ProtoMessage()

func (*Url) ProtoReflect 

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

func (*Url) Reset 

func (x *Url) Reset()

func (*Url) String 

func (x *Url) String() string

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.