connection

package
v0.8.11 Latest Latest
Warning

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

Go to latest
Published: Apr 18, 2022 License: Apache-2.0 Imports: 21 Imported by: 6

Documentation

Overview

Package connection is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var Connection_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aserto.tenant.connection.v1.Connection",
	HandlerType: (*ConnectionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListConnections",
			Handler:    _Connection_ListConnections_Handler,
		},
		{
			MethodName: "GetConnection",
			Handler:    _Connection_GetConnection_Handler,
		},
		{
			MethodName: "CreateConnection",
			Handler:    _Connection_CreateConnection_Handler,
		},
		{
			MethodName: "UpdateConnection",
			Handler:    _Connection_UpdateConnection_Handler,
		},
		{
			MethodName: "DeleteConnection",
			Handler:    _Connection_DeleteConnection_Handler,
		},
		{
			MethodName: "VerifyConnection",
			Handler:    _Connection_VerifyConnection_Handler,
		},
		{
			MethodName: "RotateSecret",
			Handler:    _Connection_RotateSecret_Handler,
		},
		{
			MethodName: "ConnectionAvailable",
			Handler:    _Connection_ConnectionAvailable_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aserto/tenant/connection/v1/connection.proto",
}

Connection_ServiceDesc is the grpc.ServiceDesc for Connection 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_aserto_tenant_connection_v1_connection_proto protoreflect.FileDescriptor

Functions

func RegisterConnectionHandler

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

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

func RegisterConnectionHandlerClient

func RegisterConnectionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ConnectionClient) error

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

func RegisterConnectionHandlerFromEndpoint

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

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

func RegisterConnectionHandlerServer

func RegisterConnectionHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ConnectionServer) error

RegisterConnectionHandlerServer registers the http handlers for service Connection to "mux". UnaryRPC :call ConnectionServer 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 RegisterConnectionHandlerFromEndpoint instead.

func RegisterConnectionServer

func RegisterConnectionServer(s grpc.ServiceRegistrar, srv ConnectionServer)

Types

type ConnectionAvailableRequest added in v0.8.5

type ConnectionAvailableRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionAvailableRequest) Descriptor deprecated added in v0.8.5

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

Deprecated: Use ConnectionAvailableRequest.ProtoReflect.Descriptor instead.

func (*ConnectionAvailableRequest) GetName added in v0.8.5

func (x *ConnectionAvailableRequest) GetName() string

func (*ConnectionAvailableRequest) ProtoMessage added in v0.8.5

func (*ConnectionAvailableRequest) ProtoMessage()

func (*ConnectionAvailableRequest) ProtoReflect added in v0.8.5

func (*ConnectionAvailableRequest) Reset added in v0.8.5

func (x *ConnectionAvailableRequest) Reset()

func (*ConnectionAvailableRequest) String added in v0.8.5

func (x *ConnectionAvailableRequest) String() string

type ConnectionAvailableResponse added in v0.8.5

type ConnectionAvailableResponse struct {
	Availability v1.NameAvailability `protobuf:"varint,1,opt,name=availability,proto3,enum=aserto.api.v1.NameAvailability" json:"availability,omitempty"`
	Reason       string              `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionAvailableResponse) Descriptor deprecated added in v0.8.5

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

Deprecated: Use ConnectionAvailableResponse.ProtoReflect.Descriptor instead.

func (*ConnectionAvailableResponse) GetAvailability added in v0.8.5

func (x *ConnectionAvailableResponse) GetAvailability() v1.NameAvailability

func (*ConnectionAvailableResponse) GetReason added in v0.8.5

func (x *ConnectionAvailableResponse) GetReason() string

func (*ConnectionAvailableResponse) ProtoMessage added in v0.8.5

func (*ConnectionAvailableResponse) ProtoMessage()

func (*ConnectionAvailableResponse) ProtoReflect added in v0.8.5

func (*ConnectionAvailableResponse) Reset added in v0.8.5

func (x *ConnectionAvailableResponse) Reset()

func (*ConnectionAvailableResponse) String added in v0.8.5

func (x *ConnectionAvailableResponse) String() string

type ConnectionClient

ConnectionClient is the client API for Connection 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 NewConnectionClient

func NewConnectionClient(cc grpc.ClientConnInterface) ConnectionClient

type ConnectionServer

ConnectionServer is the server API for Connection service. All implementations should embed UnimplementedConnectionServer for forward compatibility

type CreateConnectionRequest

type CreateConnectionRequest struct {
	Connection *v1.Connection `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConnectionRequest) Descriptor deprecated

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

Deprecated: Use CreateConnectionRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectionRequest) GetConnection

func (x *CreateConnectionRequest) GetConnection() *v1.Connection

func (*CreateConnectionRequest) ProtoMessage

func (*CreateConnectionRequest) ProtoMessage()

func (*CreateConnectionRequest) ProtoReflect

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

func (*CreateConnectionRequest) Reset

func (x *CreateConnectionRequest) Reset()

func (*CreateConnectionRequest) String

func (x *CreateConnectionRequest) String() string

type CreateConnectionResponse

type CreateConnectionResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConnectionResponse) Descriptor deprecated

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

Deprecated: Use CreateConnectionResponse.ProtoReflect.Descriptor instead.

func (*CreateConnectionResponse) GetId

func (x *CreateConnectionResponse) GetId() string

func (*CreateConnectionResponse) ProtoMessage

func (*CreateConnectionResponse) ProtoMessage()

func (*CreateConnectionResponse) ProtoReflect

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

func (*CreateConnectionResponse) Reset

func (x *CreateConnectionResponse) Reset()

func (*CreateConnectionResponse) String

func (x *CreateConnectionResponse) String() string

type DeleteConnectionRequest

type DeleteConnectionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConnectionRequest) Descriptor deprecated

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

Deprecated: Use DeleteConnectionRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectionRequest) GetId

func (x *DeleteConnectionRequest) GetId() string

func (*DeleteConnectionRequest) ProtoMessage

func (*DeleteConnectionRequest) ProtoMessage()

func (*DeleteConnectionRequest) ProtoReflect

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

func (*DeleteConnectionRequest) Reset

func (x *DeleteConnectionRequest) Reset()

func (*DeleteConnectionRequest) String

func (x *DeleteConnectionRequest) String() string

type DeleteConnectionResponse

type DeleteConnectionResponse struct {
	Results *emptypb.Empty `protobuf:"bytes,1,opt,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConnectionResponse) Descriptor deprecated

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

Deprecated: Use DeleteConnectionResponse.ProtoReflect.Descriptor instead.

func (*DeleteConnectionResponse) GetResults

func (x *DeleteConnectionResponse) GetResults() *emptypb.Empty

func (*DeleteConnectionResponse) ProtoMessage

func (*DeleteConnectionResponse) ProtoMessage()

func (*DeleteConnectionResponse) ProtoReflect

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

func (*DeleteConnectionResponse) Reset

func (x *DeleteConnectionResponse) Reset()

func (*DeleteConnectionResponse) String

func (x *DeleteConnectionResponse) String() string

type GetConnectionRequest

type GetConnectionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectionRequest) Descriptor deprecated

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

Deprecated: Use GetConnectionRequest.ProtoReflect.Descriptor instead.

func (*GetConnectionRequest) GetId

func (x *GetConnectionRequest) GetId() string

func (*GetConnectionRequest) ProtoMessage

func (*GetConnectionRequest) ProtoMessage()

func (*GetConnectionRequest) ProtoReflect

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

func (*GetConnectionRequest) Reset

func (x *GetConnectionRequest) Reset()

func (*GetConnectionRequest) String

func (x *GetConnectionRequest) String() string

type GetConnectionResponse

type GetConnectionResponse struct {
	Result *v1.Connection `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectionResponse) Descriptor deprecated

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

Deprecated: Use GetConnectionResponse.ProtoReflect.Descriptor instead.

func (*GetConnectionResponse) GetResult

func (x *GetConnectionResponse) GetResult() *v1.Connection

func (*GetConnectionResponse) ProtoMessage

func (*GetConnectionResponse) ProtoMessage()

func (*GetConnectionResponse) ProtoReflect

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

func (*GetConnectionResponse) Reset

func (x *GetConnectionResponse) Reset()

func (*GetConnectionResponse) String

func (x *GetConnectionResponse) String() string

type ListConnectionsRequest

type ListConnectionsRequest struct {
	Kind v1.ProviderKind `protobuf:"varint,1,opt,name=kind,proto3,enum=aserto.api.v1.ProviderKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectionsRequest) Descriptor deprecated

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

Deprecated: Use ListConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectionsRequest) GetKind

func (x *ListConnectionsRequest) GetKind() v1.ProviderKind

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 {
	Results []*v1.Connection `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectionsResponse) Descriptor deprecated

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

Deprecated: Use ListConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectionsResponse) GetResults

func (x *ListConnectionsResponse) GetResults() []*v1.Connection

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 RotateSecretRequest

type RotateSecretRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SecretKey string `protobuf:"bytes,2,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*RotateSecretRequest) Descriptor deprecated

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

Deprecated: Use RotateSecretRequest.ProtoReflect.Descriptor instead.

func (*RotateSecretRequest) GetId

func (x *RotateSecretRequest) GetId() string

func (*RotateSecretRequest) GetSecretKey

func (x *RotateSecretRequest) GetSecretKey() string

func (*RotateSecretRequest) ProtoMessage

func (*RotateSecretRequest) ProtoMessage()

func (*RotateSecretRequest) ProtoReflect

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

func (*RotateSecretRequest) Reset

func (x *RotateSecretRequest) Reset()

func (*RotateSecretRequest) String

func (x *RotateSecretRequest) String() string

type RotateSecretResponse

type RotateSecretResponse struct {
	Result *v1.Connection `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RotateSecretResponse) Descriptor deprecated

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

Deprecated: Use RotateSecretResponse.ProtoReflect.Descriptor instead.

func (*RotateSecretResponse) GetResult

func (x *RotateSecretResponse) GetResult() *v1.Connection

func (*RotateSecretResponse) ProtoMessage

func (*RotateSecretResponse) ProtoMessage()

func (*RotateSecretResponse) ProtoReflect

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

func (*RotateSecretResponse) Reset

func (x *RotateSecretResponse) Reset()

func (*RotateSecretResponse) String

func (x *RotateSecretResponse) String() string

type UnimplementedConnectionServer

type UnimplementedConnectionServer struct {
}

UnimplementedConnectionServer should be embedded to have forward compatible implementations.

func (UnimplementedConnectionServer) ConnectionAvailable added in v0.8.5

func (UnimplementedConnectionServer) CreateConnection

func (UnimplementedConnectionServer) DeleteConnection

func (UnimplementedConnectionServer) GetConnection

func (UnimplementedConnectionServer) ListConnections

func (UnimplementedConnectionServer) RotateSecret

func (UnimplementedConnectionServer) UpdateConnection

func (UnimplementedConnectionServer) VerifyConnection

type UnsafeConnectionServer

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

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

type UpdateConnectionRequest

type UpdateConnectionRequest struct {
	Connection *v1.Connection `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	Force      bool           `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` // Use to force an update for readonly fields
	// contains filtered or unexported fields
}

func (*UpdateConnectionRequest) Descriptor deprecated

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

Deprecated: Use UpdateConnectionRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectionRequest) GetConnection

func (x *UpdateConnectionRequest) GetConnection() *v1.Connection

func (*UpdateConnectionRequest) GetForce

func (x *UpdateConnectionRequest) GetForce() bool

func (*UpdateConnectionRequest) ProtoMessage

func (*UpdateConnectionRequest) ProtoMessage()

func (*UpdateConnectionRequest) ProtoReflect

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

func (*UpdateConnectionRequest) Reset

func (x *UpdateConnectionRequest) Reset()

func (*UpdateConnectionRequest) String

func (x *UpdateConnectionRequest) String() string

type UpdateConnectionResponse

type UpdateConnectionResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectionResponse) Descriptor deprecated

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

Deprecated: Use UpdateConnectionResponse.ProtoReflect.Descriptor instead.

func (*UpdateConnectionResponse) GetId

func (x *UpdateConnectionResponse) GetId() string

func (*UpdateConnectionResponse) ProtoMessage

func (*UpdateConnectionResponse) ProtoMessage()

func (*UpdateConnectionResponse) ProtoReflect

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

func (*UpdateConnectionResponse) Reset

func (x *UpdateConnectionResponse) Reset()

func (*UpdateConnectionResponse) String

func (x *UpdateConnectionResponse) String() string

type VerifyConnectionRequest

type VerifyConnectionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyConnectionRequest) Descriptor deprecated

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

Deprecated: Use VerifyConnectionRequest.ProtoReflect.Descriptor instead.

func (*VerifyConnectionRequest) GetId

func (x *VerifyConnectionRequest) GetId() string

func (*VerifyConnectionRequest) ProtoMessage

func (*VerifyConnectionRequest) ProtoMessage()

func (*VerifyConnectionRequest) ProtoReflect

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

func (*VerifyConnectionRequest) Reset

func (x *VerifyConnectionRequest) Reset()

func (*VerifyConnectionRequest) String

func (x *VerifyConnectionRequest) String() string

type VerifyConnectionResponse

type VerifyConnectionResponse struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyConnectionResponse) Descriptor deprecated

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

Deprecated: Use VerifyConnectionResponse.ProtoReflect.Descriptor instead.

func (*VerifyConnectionResponse) GetStatus

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

func (*VerifyConnectionResponse) ProtoMessage

func (*VerifyConnectionResponse) ProtoMessage()

func (*VerifyConnectionResponse) ProtoReflect

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

func (*VerifyConnectionResponse) Reset

func (x *VerifyConnectionResponse) Reset()

func (*VerifyConnectionResponse) String

func (x *VerifyConnectionResponse) String() string

Jump to

Keyboard shortcuts

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