Documentation
¶
Index ¶
- Constants
- func MapPrivateEndpoints(akoInterfaces, atlasInterfaces []EndpointInterface) map[string]CompositeEndpointInterface
- func NewPrivateEndpointStatus(peService EndpointService) status.AtlasPrivateEndpointStatusOption
- type AWSInterface
- type AWSService
- type AzureInterface
- type AzureService
- type CommonEndpointInterface
- type CommonEndpointService
- type CompositeEndpointInterface
- type EndpointInterface
- type EndpointInterfaces
- type EndpointService
- type GCPInterface
- type GCPInterfaceEndpoint
- type GCPService
- type PrivateEndpoint
- func (pe *PrivateEndpoint) CreatePrivateEndpointInterface(ctx context.Context, projectID, provider, serviceID, gcpProjectID string, ...) (EndpointInterface, error)
- func (pe *PrivateEndpoint) CreatePrivateEndpointService(ctx context.Context, projectID string, peService EndpointService) (EndpointService, error)
- func (pe *PrivateEndpoint) DeleteEndpointInterface(ctx context.Context, projectID, provider, serviceID, ID string) error
- func (pe *PrivateEndpoint) DeleteEndpointService(ctx context.Context, projectID, provider, ID string) error
- func (pe *PrivateEndpoint) GetPrivateEndpoint(ctx context.Context, projectID, provider, ID string) (EndpointService, error)
- func (pe *PrivateEndpoint) ListPrivateEndpoints(ctx context.Context, projectID, provider string) ([]EndpointService, error)
- type PrivateEndpointService
Constants ¶
View Source
const ( ProviderAWS = "AWS" ProviderAzure = "AZURE" ProviderGCP = "GCP" StatusInitiating = "INITIATING" StatusPending = "PENDING" StatusPendingAcceptance = "PENDING_ACCEPTANCE" StatusWaitingForUser = "WAITING_FOR_USER" StatusVerified = "VERIFIED" StatusFailed = "FAILED" StatusRejected = "REJECTED" StatusDeleting = "DELETING" )
View Source
const (
ErrorServiceNotFound = "PRIVATE_ENDPOINT_SERVICE_NOT_FOUND"
)
Variables ¶
This section is empty.
Functions ¶
func MapPrivateEndpoints ¶
func MapPrivateEndpoints(akoInterfaces, atlasInterfaces []EndpointInterface) map[string]CompositeEndpointInterface
func NewPrivateEndpointStatus ¶
func NewPrivateEndpointStatus(peService EndpointService) status.AtlasPrivateEndpointStatusOption
Types ¶
type AWSInterface ¶
type AWSInterface struct {
CommonEndpointInterface
}
type AWSService ¶
type AWSService struct {
CommonEndpointService
ServiceName string
}
func (*AWSService) Provider ¶
func (s *AWSService) Provider() string
type AzureInterface ¶
type AzureInterface struct {
CommonEndpointInterface
IP string
ConnectionName string
}
type AzureService ¶
type AzureService struct {
CommonEndpointService
ServiceName string
ResourceID string
}
func (*AzureService) Provider ¶
func (s *AzureService) Provider() string
type CommonEndpointInterface ¶
func (*CommonEndpointInterface) ErrorMessage ¶
func (i *CommonEndpointInterface) ErrorMessage() string
func (*CommonEndpointInterface) InterfaceID ¶
func (i *CommonEndpointInterface) InterfaceID() string
func (*CommonEndpointInterface) Status ¶
func (i *CommonEndpointInterface) Status() string
type CommonEndpointService ¶
type CommonEndpointService struct {
ID string
CloudRegion string
ServiceStatus string
Error string
Interfaces EndpointInterfaces
}
func (*CommonEndpointService) EndpointInterfaces ¶
func (s *CommonEndpointService) EndpointInterfaces() EndpointInterfaces
func (*CommonEndpointService) ErrorMessage ¶
func (s *CommonEndpointService) ErrorMessage() string
func (*CommonEndpointService) Region ¶
func (s *CommonEndpointService) Region() string
func (*CommonEndpointService) ServiceID ¶
func (s *CommonEndpointService) ServiceID() string
func (*CommonEndpointService) Status ¶
func (s *CommonEndpointService) Status() string
type CompositeEndpointInterface ¶
type CompositeEndpointInterface struct {
AKO EndpointInterface
Atlas EndpointInterface
}
type EndpointInterface ¶
type EndpointInterfaces ¶
type EndpointInterfaces []EndpointInterface
func (EndpointInterfaces) Get ¶
func (ei EndpointInterfaces) Get(ID string) EndpointInterface
type EndpointService ¶
type EndpointService interface {
ServiceID() string
EndpointInterfaces() EndpointInterfaces
Provider() string
Region() string
Status() string
ErrorMessage() string
}
func NewPrivateEndpoint ¶
func NewPrivateEndpoint(akoPrivateEndpoint *akov2.AtlasPrivateEndpoint) EndpointService
type GCPInterface ¶
type GCPInterface struct {
CommonEndpointInterface
Endpoints []GCPInterfaceEndpoint
}
type GCPInterfaceEndpoint ¶
type GCPService ¶
type GCPService struct {
CommonEndpointService
AttachmentNames []string
}
func (*GCPService) Provider ¶
func (s *GCPService) Provider() string
type PrivateEndpoint ¶
type PrivateEndpoint struct {
// contains filtered or unexported fields
}
func (*PrivateEndpoint) CreatePrivateEndpointInterface ¶
func (pe *PrivateEndpoint) CreatePrivateEndpointInterface(ctx context.Context, projectID, provider, serviceID, gcpProjectID string, peInterface EndpointInterface) (EndpointInterface, error)
func (*PrivateEndpoint) CreatePrivateEndpointService ¶
func (pe *PrivateEndpoint) CreatePrivateEndpointService(ctx context.Context, projectID string, peService EndpointService) (EndpointService, error)
func (*PrivateEndpoint) DeleteEndpointInterface ¶
func (pe *PrivateEndpoint) DeleteEndpointInterface(ctx context.Context, projectID, provider, serviceID, ID string) error
func (*PrivateEndpoint) DeleteEndpointService ¶
func (pe *PrivateEndpoint) DeleteEndpointService(ctx context.Context, projectID, provider, ID string) error
func (*PrivateEndpoint) GetPrivateEndpoint ¶
func (pe *PrivateEndpoint) GetPrivateEndpoint(ctx context.Context, projectID, provider, ID string) (EndpointService, error)
func (*PrivateEndpoint) ListPrivateEndpoints ¶
func (pe *PrivateEndpoint) ListPrivateEndpoints(ctx context.Context, projectID, provider string) ([]EndpointService, error)
type PrivateEndpointService ¶
type PrivateEndpointService interface {
ListPrivateEndpoints(ctx context.Context, projectID, provider string) ([]EndpointService, error)
GetPrivateEndpoint(ctx context.Context, projectID, provider, ID string) (EndpointService, error)
CreatePrivateEndpointService(ctx context.Context, projectID string, peService EndpointService) (EndpointService, error)
DeleteEndpointService(ctx context.Context, projectID, provider, ID string) error
CreatePrivateEndpointInterface(ctx context.Context, projectID, provider, serviceID, gcpProjectID string, peInterface EndpointInterface) (EndpointInterface, error)
DeleteEndpointInterface(ctx context.Context, projectID, provider, serviceID, ID string) error
}
func NewPrivateEndpointAPI ¶
func NewPrivateEndpointAPI(api admin.PrivateEndpointServicesApi) PrivateEndpointService
Click to show internal directories.
Click to hide internal directories.