networkpeering

package
v2.10.1-prerelease-cha... Latest Latest
Warning

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

Go to latest
Published: Aug 20, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrNotFound means an resource is missing
	ErrNotFound = errors.New("not found")
)
View Source
var (
	// ErrUnsupportedProvider marks an error when parsing an invalid provider input
	ErrUnsupportedProvider = errors.New("unsupported provider")
)

Functions

func ApplyPeeringStatus added in v2.8.0

func ApplyPeeringStatus(peeringStatus *status.AtlasNetworkPeeringStatus, peer *NetworkPeer, container *networkcontainer.NetworkContainer)

func ClearPeeringStatus added in v2.8.0

func ClearPeeringStatus(peeringStatus *status.AtlasNetworkPeeringStatus)

func CompareConfigs added in v2.8.0

func CompareConfigs(a, b *NetworkPeer) bool

Types

type NetworkPeer

type NetworkPeer struct {
	akov2.AtlasNetworkPeeringConfig
	ContainerID  string
	Status       string
	ErrorMessage string
	AWSStatus    *status.AWSPeeringStatus
}

func NewNetworkPeer

func NewNetworkPeer(id string, cfg *akov2.AtlasNetworkPeeringConfig) *NetworkPeer

NewNetworkPeer creates a network peering from the given config

func (*NetworkPeer) AWSConnectionID added in v2.8.0

func (np *NetworkPeer) AWSConnectionID() string

func (*NetworkPeer) Available added in v2.8.0

func (np *NetworkPeer) Available() bool

Available returns whether or not the Network Peering is connected and ready to use

func (*NetworkPeer) Closing added in v2.8.0

func (np *NetworkPeer) Closing() bool

Closing returns whether or not the Network Peering is being shut down

func (*NetworkPeer) Failed added in v2.8.0

func (np *NetworkPeer) Failed() bool

func (*NetworkPeer) String added in v2.8.0

func (np *NetworkPeer) String() string

func (*NetworkPeer) UpdateStatus added in v2.8.0

func (np *NetworkPeer) UpdateStatus(atlas *NetworkPeer)

UpdateStatus copies the network peering status fields only from the given peer input

type NetworkPeeringService

type NetworkPeeringService interface {
	Create(ctx context.Context, projectID, containerID string, cfg *akov2.AtlasNetworkPeeringConfig) (*NetworkPeer, error)
	Get(ctx context.Context, projectID, peerID string) (*NetworkPeer, error)
	Update(ctx context.Context, pojectID, peerID, containerID string, cfg *akov2.AtlasNetworkPeeringConfig) (*NetworkPeer, error)
	Delete(ctx context.Context, projectID, peerID string) error
}

func NewNetworkPeeringService

func NewNetworkPeeringService(peeringAPI admin.NetworkPeeringApi) NetworkPeeringService

func NewNetworkPeeringServiceFromClientSet added in v2.8.0

func NewNetworkPeeringServiceFromClientSet(clientSet *atlas.ClientSet) NetworkPeeringService

Jump to

Keyboard shortcuts

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