connection

package
v0.0.45 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 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,
		},
	},
	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 ConnectionClient 

type ConnectionClient interface {
	ListConnections(ctx context.Context, in *ListConnectionsRequest, opts ...grpc.CallOption) (*ListConnectionsResponse, error)
	GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*GetConnectionResponse, error)
	CreateConnection(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*CreateConnectionResponse, error)
	UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*UpdateConnectionResponse, error)
	DeleteConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*DeleteConnectionResponse, error)
	VerifyConnection(ctx context.Context, in *VerifyConnectionRequest, opts ...grpc.CallOption) (*VerifyConnectionResponse, error)
	RotateSecret(ctx context.Context, in *RotateSecretRequest, opts ...grpc.CallOption) (*RotateSecretResponse, error)
}

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 

type ConnectionServer interface {
	ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)
	GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)
	CreateConnection(context.Context, *CreateConnectionRequest) (*CreateConnectionResponse, error)
	UpdateConnection(context.Context, *UpdateConnectionRequest) (*UpdateConnectionResponse, error)
	DeleteConnection(context.Context, *DeleteConnectionRequest) (*DeleteConnectionResponse, error)
	VerifyConnection(context.Context, *VerifyConnectionRequest) (*VerifyConnectionResponse, error)
	RotateSecret(context.Context, *RotateSecretRequest) (*RotateSecretResponse, error)
}

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

func (UnimplementedConnectionServer) CreateConnection(context.Context, *CreateConnectionRequest) (*CreateConnectionResponse, error)

func (UnimplementedConnectionServer) DeleteConnection 

func (UnimplementedConnectionServer) DeleteConnection(context.Context, *DeleteConnectionRequest) (*DeleteConnectionResponse, error)

func (UnimplementedConnectionServer) GetConnection 

func (UnimplementedConnectionServer) GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)

func (UnimplementedConnectionServer) ListConnections 

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

func (UnimplementedConnectionServer) RotateSecret 

func (UnimplementedConnectionServer) RotateSecret(context.Context, *RotateSecretRequest) (*RotateSecretResponse, error)

func (UnimplementedConnectionServer) UpdateConnection 

func (UnimplementedConnectionServer) UpdateConnection(context.Context, *UpdateConnectionRequest) (*UpdateConnectionResponse, error)

func (UnimplementedConnectionServer) VerifyConnection 

func (UnimplementedConnectionServer) VerifyConnection(context.Context, *VerifyConnectionRequest) (*VerifyConnectionResponse, error)

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

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.