vpcaccesspb

package
v0.0.0-...-bead1b6 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package vpcaccesspb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	Connector_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "READY",
		2: "CREATING",
		3: "DELETING",
		4: "ERROR",
		5: "UPDATING",
	}
	Connector_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"READY":             1,
		"CREATING":          2,
		"DELETING":          3,
		"ERROR":             4,
		"UPDATING":          5,
	}
)

Enum value maps for Connector_State.

View Source 
var File_mockgcp_cloud_vpcaccess_v1_vpc_access_proto protoreflect.FileDescriptor
View Source 
var VpcAccessService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mockgcp.cloud.vpcaccess.v1.VpcAccessService",
	HandlerType: (*VpcAccessServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateConnector",
			Handler:    _VpcAccessService_CreateConnector_Handler,
		},
		{
			MethodName: "GetConnector",
			Handler:    _VpcAccessService_GetConnector_Handler,
		},
		{
			MethodName: "ListConnectors",
			Handler:    _VpcAccessService_ListConnectors_Handler,
		},
		{
			MethodName: "DeleteConnector",
			Handler:    _VpcAccessService_DeleteConnector_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mockgcp/cloud/vpcaccess/v1/vpc_access.proto",
}

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

Functions

func RegisterVpcAccessServiceHandler 

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

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

func RegisterVpcAccessServiceHandlerClient 

func RegisterVpcAccessServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VpcAccessServiceClient) error

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

func RegisterVpcAccessServiceHandlerFromEndpoint 

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

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

func RegisterVpcAccessServiceHandlerServer 

func RegisterVpcAccessServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server VpcAccessServiceServer) error

RegisterVpcAccessServiceHandlerServer registers the http handlers for service VpcAccessService to "mux". UnaryRPC :call VpcAccessServiceServer 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 RegisterVpcAccessServiceHandlerFromEndpoint instead.

func RegisterVpcAccessServiceServer 

func RegisterVpcAccessServiceServer(s grpc.ServiceRegistrar, srv VpcAccessServiceServer)

Types

type Connector 

type Connector struct {

	// The resource name in the format `projects/*/locations/*/connectors/*`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of a VPC network.
	Network string `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
	// The range of internal addresses that follows RFC 4632 notation.
	// Example: `10.132.0.0/28`.
	IpCidrRange string `protobuf:"bytes,3,opt,name=ip_cidr_range,json=ipCidrRange,proto3" json:"ip_cidr_range,omitempty"`
	// Output only. State of the VPC access connector.
	State Connector_State `protobuf:"varint,4,opt,name=state,proto3,enum=mockgcp.cloud.vpcaccess.v1.Connector_State" json:"state,omitempty"`
	// Minimum throughput of the connector in Mbps. Default and min is 200.
	MinThroughput int32 `protobuf:"varint,5,opt,name=min_throughput,json=minThroughput,proto3" json:"min_throughput,omitempty"`
	// Maximum throughput of the connector in Mbps. Default is 300, max is 1000.
	MaxThroughput int32 `protobuf:"varint,6,opt,name=max_throughput,json=maxThroughput,proto3" json:"max_throughput,omitempty"`
	// Output only. List of projects using the connector.
	ConnectedProjects []string `protobuf:"bytes,7,rep,name=connected_projects,json=connectedProjects,proto3" json:"connected_projects,omitempty"`
	// The subnet in which to house the VPC Access Connector.
	Subnet *Connector_Subnet `protobuf:"bytes,8,opt,name=subnet,proto3" json:"subnet,omitempty"`
	// Machine type of VM Instance underlying connector. Default is e2-micro
	MachineType string `protobuf:"bytes,10,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// Minimum value of instances in autoscaling group underlying the connector.
	MinInstances int32 `protobuf:"varint,11,opt,name=min_instances,json=minInstances,proto3" json:"min_instances,omitempty"`
	// Maximum value of instances in autoscaling group underlying the connector.
	MaxInstances int32 `protobuf:"varint,12,opt,name=max_instances,json=maxInstances,proto3" json:"max_instances,omitempty"`
	// contains filtered or unexported fields
}

Definition of a Serverless VPC Access connector.

func (*Connector) Descriptor deprecated 

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

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetConnectedProjects 

func (x *Connector) GetConnectedProjects() []string

func (*Connector) GetIpCidrRange 

func (x *Connector) GetIpCidrRange() string

func (*Connector) GetMachineType 

func (x *Connector) GetMachineType() string

func (*Connector) GetMaxInstances 

func (x *Connector) GetMaxInstances() int32

func (*Connector) GetMaxThroughput 

func (x *Connector) GetMaxThroughput() int32

func (*Connector) GetMinInstances 

func (x *Connector) GetMinInstances() int32

func (*Connector) GetMinThroughput 

func (x *Connector) GetMinThroughput() int32

func (*Connector) GetName 

func (x *Connector) GetName() string

func (*Connector) GetNetwork 

func (x *Connector) GetNetwork() string

func (*Connector) GetState 

func (x *Connector) GetState() Connector_State

func (*Connector) GetSubnet 

func (x *Connector) GetSubnet() *Connector_Subnet

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect 

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

func (*Connector) Reset 

func (x *Connector) Reset()

func (*Connector) String 

func (x *Connector) String() string

type Connector_State 

type Connector_State int32

State of a connector. 

const (
	// Invalid state.
	Connector_STATE_UNSPECIFIED Connector_State = 0
	// Connector is deployed and ready to receive traffic.
	Connector_READY Connector_State = 1
	// An Insert operation is in progress. Transient condition.
	Connector_CREATING Connector_State = 2
	// A Delete operation is in progress. Transient condition.
	Connector_DELETING Connector_State = 3
	// Connector is in a bad state, manual deletion recommended.
	Connector_ERROR Connector_State = 4
	// The connector is being updated.
	Connector_UPDATING Connector_State = 5
)

func (Connector_State) Descriptor 

func (Connector_State) Descriptor() protoreflect.EnumDescriptor

func (Connector_State) Enum 

func (x Connector_State) Enum() *Connector_State

func (Connector_State) EnumDescriptor deprecated 

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

Deprecated: Use Connector_State.Descriptor instead.

func (Connector_State) Number 

func (x Connector_State) Number() protoreflect.EnumNumber

func (Connector_State) String 

func (x Connector_State) String() string

func (Connector_State) Type 

func (Connector_State) Type() protoreflect.EnumType

type Connector_Subnet 

type Connector_Subnet struct {

	// Subnet name (relative, not fully qualified).
	// E.g. if the full subnet selfLink is
	// https://compute.googleapis.com/compute/v1/projects/{project}/regions/{region}/subnetworks/{subnetName}
	// the correct input for this field would be {subnetName}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Project in which the subnet exists.
	// If not set, this project is assumed to be the project for which
	// the connector create request was issued.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

The subnet in which to house the connector

func (*Connector_Subnet) Descriptor deprecated 

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

Deprecated: Use Connector_Subnet.ProtoReflect.Descriptor instead.

func (*Connector_Subnet) GetName 

func (x *Connector_Subnet) GetName() string

func (*Connector_Subnet) GetProjectId 

func (x *Connector_Subnet) GetProjectId() string

func (*Connector_Subnet) ProtoMessage 

func (*Connector_Subnet) ProtoMessage()

func (*Connector_Subnet) ProtoReflect 

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

func (*Connector_Subnet) Reset 

func (x *Connector_Subnet) Reset()

func (*Connector_Subnet) String 

func (x *Connector_Subnet) String() string

type CreateConnectorRequest 

type CreateConnectorRequest struct {

	// Required. The project and location in which the configuration should be created,
	// specified in the format `projects/*/locations/*`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The ID to use for this connector.
	ConnectorId string `protobuf:"bytes,2,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// Required. Resource to create.
	Connector *Connector `protobuf:"bytes,3,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

Request for creating a Serverless VPC Access connector.

func (*CreateConnectorRequest) Descriptor deprecated 

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

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetConnector 

func (x *CreateConnectorRequest) GetConnector() *Connector

func (*CreateConnectorRequest) GetConnectorId 

func (x *CreateConnectorRequest) GetConnectorId() string

func (*CreateConnectorRequest) GetParent 

func (x *CreateConnectorRequest) GetParent() string

func (*CreateConnectorRequest) ProtoMessage 

func (*CreateConnectorRequest) ProtoMessage()

func (*CreateConnectorRequest) ProtoReflect 

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

func (*CreateConnectorRequest) Reset 

func (x *CreateConnectorRequest) Reset()

func (*CreateConnectorRequest) String 

func (x *CreateConnectorRequest) String() string

type DeleteConnectorRequest 

type DeleteConnectorRequest struct {

	// Required. Name of a Serverless VPC Access connector to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for deleting a Serverless VPC Access connector.

func (*DeleteConnectorRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetName 

func (x *DeleteConnectorRequest) GetName() string

func (*DeleteConnectorRequest) ProtoMessage 

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect 

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

func (*DeleteConnectorRequest) Reset 

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) String 

func (x *DeleteConnectorRequest) String() string

type GetConnectorRequest 

type GetConnectorRequest struct {

	// Required. Name of a Serverless VPC Access connector to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for getting a Serverless VPC Access connector.

func (*GetConnectorRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetName 

func (x *GetConnectorRequest) GetName() string

func (*GetConnectorRequest) ProtoMessage 

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect 

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

func (*GetConnectorRequest) Reset 

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) String 

func (x *GetConnectorRequest) String() string

type ListConnectorsRequest 

type ListConnectorsRequest struct {

	// Required. The project and location from which the routes should be listed.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of functions to return per call.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Continuation token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for listing Serverless VPC Access connectors in a location.

func (*ListConnectorsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) GetPageSize 

func (x *ListConnectorsRequest) GetPageSize() int32

func (*ListConnectorsRequest) GetPageToken 

func (x *ListConnectorsRequest) GetPageToken() string

func (*ListConnectorsRequest) GetParent 

func (x *ListConnectorsRequest) GetParent() string

func (*ListConnectorsRequest) ProtoMessage 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect 

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

func (*ListConnectorsRequest) Reset 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) String 

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse 

type ListConnectorsResponse struct {

	// List of Serverless VPC Access connectors.
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	// Continuation token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for listing Serverless VPC Access connectors.

func (*ListConnectorsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors 

func (x *ListConnectorsResponse) GetConnectors() []*Connector

func (*ListConnectorsResponse) GetNextPageToken 

func (x *ListConnectorsResponse) GetNextPageToken() string

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

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

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type OperationMetadata 

type OperationMetadata struct {

	// Output only. Method that initiated the operation e.g.
	// mockgcp.cloud.vpcaccess.v1.Connectors.CreateConnector.
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// Output only. Time when the operation was created.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. Time when the operation completed.
	EndTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Name of the resource that this operation is acting on e.g.
	// projects/my-project/locations/us-central1/connectors/v1.
	Target string `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

Metadata for google.longrunning.Operation.

func (*OperationMetadata) Descriptor deprecated 

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetCreateTime 

func (x *OperationMetadata) GetCreateTime() *timestamp.Timestamp

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamp.Timestamp

func (*OperationMetadata) GetMethod 

func (x *OperationMetadata) GetMethod() string

func (*OperationMetadata) GetTarget 

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) ProtoMessage 

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect 

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

func (*OperationMetadata) Reset 

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String 

func (x *OperationMetadata) String() string

type UnimplementedVpcAccessServiceServer 

type UnimplementedVpcAccessServiceServer struct {
}

UnimplementedVpcAccessServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedVpcAccessServiceServer) CreateConnector 

func (UnimplementedVpcAccessServiceServer) CreateConnector(context.Context, *CreateConnectorRequest) (*longrunningpb.Operation, error)

func (UnimplementedVpcAccessServiceServer) DeleteConnector 

func (UnimplementedVpcAccessServiceServer) DeleteConnector(context.Context, *DeleteConnectorRequest) (*longrunningpb.Operation, error)

func (UnimplementedVpcAccessServiceServer) GetConnector 

func (UnimplementedVpcAccessServiceServer) GetConnector(context.Context, *GetConnectorRequest) (*Connector, error)

func (UnimplementedVpcAccessServiceServer) ListConnectors 

func (UnimplementedVpcAccessServiceServer) ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

type UnsafeVpcAccessServiceServer 

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

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

type VpcAccessServiceClient 

type VpcAccessServiceClient interface {
	// Creates a Serverless VPC Access connector, returns an operation.
	CreateConnector(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets a Serverless VPC Access connector. Returns NOT_FOUND if the resource
	// does not exist.
	GetConnector(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	// Lists Serverless VPC Access connectors.
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	// Deletes a Serverless VPC Access connector. Returns NOT_FOUND if the
	// resource does not exist.
	DeleteConnector(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

VpcAccessServiceClient is the client API for VpcAccessService 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 NewVpcAccessServiceClient 

func NewVpcAccessServiceClient(cc grpc.ClientConnInterface) VpcAccessServiceClient

type VpcAccessServiceServer 

type VpcAccessServiceServer interface {
	// Creates a Serverless VPC Access connector, returns an operation.
	CreateConnector(context.Context, *CreateConnectorRequest) (*longrunningpb.Operation, error)
	// Gets a Serverless VPC Access connector. Returns NOT_FOUND if the resource
	// does not exist.
	GetConnector(context.Context, *GetConnectorRequest) (*Connector, error)
	// Lists Serverless VPC Access connectors.
	ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	// Deletes a Serverless VPC Access connector. Returns NOT_FOUND if the
	// resource does not exist.
	DeleteConnector(context.Context, *DeleteConnectorRequest) (*longrunningpb.Operation, error)
	// contains filtered or unexported methods
}

VpcAccessServiceServer is the server API for VpcAccessService service. All implementations must embed UnimplementedVpcAccessServiceServer for forward compatibility

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.