privateendpoint

Documentation

Index

• Constants
• func MapPrivateEndpoints(akoInterfaces, atlasInterfaces []EndpointInterface) map[string]CompositeEndpointInterface
• func NewPrivateEndpointStatus(peService EndpointService) status.AtlasPrivateEndpointStatusOption
• type AWSInterface
• type AWSService
  • func (s *AWSService) Provider() string
• type AzureInterface
• type AzureService
  • func (s *AzureService) Provider() string
• type CommonEndpointInterface
  • func (i *CommonEndpointInterface) ErrorMessage() string
  • func (i *CommonEndpointInterface) InterfaceID() string
  • func (i *CommonEndpointInterface) Status() string
• type CommonEndpointService
  • func (s *CommonEndpointService) EndpointInterfaces() EndpointInterfaces
  • func (s *CommonEndpointService) ErrorMessage() string
  • func (s *CommonEndpointService) Region() string
  • func (s *CommonEndpointService) ServiceID() string
  • func (s *CommonEndpointService) Status() string
• type CompositeEndpointInterface
• type EndpointInterface
• type EndpointInterfaces
  • func (ei EndpointInterfaces) Get(ID string) EndpointInterface
• type EndpointService
  • func NewPrivateEndpoint(akoPrivateEndpoint *akov2.AtlasPrivateEndpoint) EndpointService
• type GCPInterface
• type GCPInterfaceEndpoint
• type GCPService
  • func (s *GCPService) Provider() string
• 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
  • func NewPrivateEndpointAPI(api admin.PrivateEndpointServicesApi) PrivateEndpointService

Constants

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

const (
	ErrorServiceNotFound = "PRIVATE_ENDPOINT_SERVICE_NOT_FOUND"
)

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

type CommonEndpointInterface struct {
	ID              string
	InterfaceStatus string
	Error           string
}

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 EndpointInterface interface {
	InterfaceID() string
	Status() string
	ErrorMessage() string
}

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 GCPInterfaceEndpoint struct {
	Name   string
	IP     string
	Status string
}

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