networkpeering

package

v2.9.0-original Latest Latest Go to latest Published: Jun 25, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mongodb/mongodb-atlas-kubernetes

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ApplyPeeringStatus(peeringStatus *status.AtlasNetworkPeeringStatus, peer *NetworkPeer, ...)
func ClearPeeringStatus(peeringStatus *status.AtlasNetworkPeeringStatus)
func CompareConfigs(a, b *NetworkPeer) bool
type NetworkPeer
- func NewNetworkPeer(id string, cfg *akov2.AtlasNetworkPeeringConfig) *NetworkPeer
type NetworkPeeringService
- func NewNetworkPeeringService(peeringAPI admin.NetworkPeeringApi) NetworkPeeringService
- func NewNetworkPeeringServiceFromClientSet(clientSet *atlas.ClientSet) NetworkPeeringService

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

Source Files ¶

View all Source files

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