atlasdatafederation

Documentation

Index

• func DataFederationFromAtlas(atlasDF *mongodbatlas.DataFederationInstance) (*mdbv1.DataFederationSpec, error)
• type AtlasDataFederationReconciler
  • func (r *AtlasDataFederationReconciler) Delete(e event.DeleteEvent) error
  • func (r *AtlasDataFederationReconciler) Reconcile(contextInt context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasDataFederationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DataFederationServiceOp
  • func NewClient(client mongodbatlas.Client, atlasDomain string) *DataFederationServiceOp
  • func (s *DataFederationServiceOp) Create(ctx context.Context, groupID string, spec *mdbv1.DataFederationSpec) (*mdbv1.DataFederationSpec, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) CreateOnePrivateEndpoint(ctx context.Context, groupID string, endpoint mdbv1.DataFederationPE) (*mdbv1.DataFederationPE, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) Delete(ctx context.Context, groupID string, tenantName string) (*mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) DeleteOnePrivateEndpoint(ctx context.Context, groupID string, endpointID string) (*mdbv1.DataFederationPE, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) Get(ctx context.Context, groupID string, tenantName string) (*mdbv1.DataFederationSpec, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) GetAllPrivateEndpoints(ctx context.Context, groupID string) ([]mdbv1.DataFederationPE, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) Update(ctx context.Context, groupID string, spec *mdbv1.DataFederationSpec) (*mdbv1.DataFederationSpec, *mongodbatlas.Response, error)
• type PrivateEndpointsResponse

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
	ObjectDeletionProtection    bool
	SubObjectDeletionProtection bool
}

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"`
}