The highest tagged major version is v2.

atlasdatafederation

package

v1.8.1 Latest Latest Go to latest Published: Aug 9, 2023 License: Apache-2.0 Imports: 33 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 ¶

func DataFederationFromAtlas(atlasDF *mongodbatlas.DataFederationInstance) (*mdbv1.DataFederationSpec, error)
type AtlasDataFederationReconciler
type DataFederationServiceOp
- func NewClient(client mongodbatlas.Client, atlasDomain string) *DataFederationServiceOp
type PrivateEndpointsResponse

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DataFederationFromAtlas ¶

func DataFederationFromAtlas(atlasDF *mongodbatlas.DataFederationInstance) (*mdbv1.DataFederationSpec, error)

Types ¶

type AtlasDataFederationReconciler ¶

type AtlasDataFederationReconciler struct {
	watch.ResourceWatcher
	Client           client.Client
	Log              *zap.SugaredLogger
	Scheme           *runtime.Scheme
	AtlasDomain      string
	GlobalAPISecret  client.ObjectKey
	GlobalPredicates []predicate.Predicate
	EventRecorder    record.EventRecorder
}

AtlasDataFederationReconciler reconciles an DataFederation object

func (*AtlasDataFederationReconciler) Delete ¶

func (r *AtlasDataFederationReconciler) Delete(e event.DeleteEvent) error

Delete implements a handler for the Delete event

func (*AtlasDataFederationReconciler) Reconcile ¶

func (r *AtlasDataFederationReconciler) Reconcile(contextInt context.Context, req ctrl.Request) (ctrl.Result, error)

func (*AtlasDataFederationReconciler) SetupWithManager ¶

func (r *AtlasDataFederationReconciler) SetupWithManager(mgr ctrl.Manager) error

type DataFederationServiceOp ¶

type DataFederationServiceOp service

func NewClient ¶

func NewClient(client mongodbatlas.Client, atlasDomain string) *DataFederationServiceOp

func (*DataFederationServiceOp) Create ¶

func (s *DataFederationServiceOp) Create(ctx context.Context, groupID string, spec *mdbv1.DataFederationSpec) (*mdbv1.DataFederationSpec, *mongodbatlas.Response, error)

func (*DataFederationServiceOp) CreateOnePrivateEndpoint ¶

func (s *DataFederationServiceOp) CreateOnePrivateEndpoint(ctx context.Context, groupID string, endpoint mdbv1.DataFederationPE) (*mdbv1.DataFederationPE, *mongodbatlas.Response, error)

func (*DataFederationServiceOp) Delete ¶

func (s *DataFederationServiceOp) Delete(ctx context.Context, groupID string, tenantName string) (*mongodbatlas.Response, error)

func (*DataFederationServiceOp) DeleteOnePrivateEndpoint ¶

func (s *DataFederationServiceOp) DeleteOnePrivateEndpoint(ctx context.Context, groupID string, endpointID string) (*mdbv1.DataFederationPE, *mongodbatlas.Response, error)

func (*DataFederationServiceOp) Get ¶

func (s *DataFederationServiceOp) Get(ctx context.Context, groupID string, tenantName string) (*mdbv1.DataFederationSpec, *mongodbatlas.Response, error)

func (*DataFederationServiceOp) GetAllPrivateEndpoints ¶

func (s *DataFederationServiceOp) GetAllPrivateEndpoints(ctx context.Context, groupID string) ([]mdbv1.DataFederationPE, *mongodbatlas.Response, error)

func (*DataFederationServiceOp) Update ¶

func (s *DataFederationServiceOp) Update(ctx context.Context, groupID string, spec *mdbv1.DataFederationSpec) (*mdbv1.DataFederationSpec, *mongodbatlas.Response, error)

type PrivateEndpointsResponse ¶

type PrivateEndpointsResponse struct {
	Links      []*mongodbatlas.Link     `json:"links,omitempty"`
	Results    []mdbv1.DataFederationPE `json:"results,omitempty"`
	TotalCount int                      `json:"totalCount,omitempty"`
}

Source Files ¶

View all Source files

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