atlasdatafederation

Documentation

Index

• func DataFederationFromAtlas(atlasDF *mongodbatlas.DataFederationInstance) (*akov2.DataFederationSpec, error)
• type AtlasDataFederationReconciler
  • func (r *AtlasDataFederationReconciler) Delete(ctx context.Context, e event.DeleteEvent) error
  • func (r *AtlasDataFederationReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasDataFederationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DataFederationServiceOp
  • func NewClient(client *mongodbatlas.Client) *DataFederationServiceOp
  • func (s *DataFederationServiceOp) Create(ctx context.Context, groupID string, spec *akov2.DataFederationSpec) (*akov2.DataFederationSpec, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) CreateOnePrivateEndpoint(ctx context.Context, groupID string, endpoint akov2.DataFederationPE) (*akov2.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) (*akov2.DataFederationPE, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) Get(ctx context.Context, groupID string, tenantName string) (*akov2.DataFederationSpec, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) GetAllPrivateEndpoints(ctx context.Context, groupID string) ([]akov2.DataFederationPE, *mongodbatlas.Response, error)
  • func (s *DataFederationServiceOp) Update(ctx context.Context, groupID string, spec *akov2.DataFederationSpec) (*akov2.DataFederationSpec, *mongodbatlas.Response, error)
• type PrivateEndpointsResponse

Functions

func DataFederationFromAtlas

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

Types

type AtlasDataFederationReconciler

type AtlasDataFederationReconciler struct {
	watch.ResourceWatcher
	Client                      client.Client
	Log                         *zap.SugaredLogger
	Scheme                      *runtime.Scheme
	GlobalPredicates            []predicate.Predicate
	EventRecorder               record.EventRecorder
	AtlasProvider               atlas.Provider
	ObjectDeletionProtection    bool
	SubObjectDeletionProtection bool
}

AtlasDataFederationReconciler reconciles an DataFederation object

func (*AtlasDataFederationReconciler) Delete

func (r *AtlasDataFederationReconciler) Delete(ctx context.Context, e event.DeleteEvent) error

Delete implements a handler for the Delete event

func (*AtlasDataFederationReconciler) Reconcile

func (r *AtlasDataFederationReconciler) Reconcile(context 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) *DataFederationServiceOp

func (*DataFederationServiceOp) Create

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

func (*DataFederationServiceOp) CreateOnePrivateEndpoint

func (s *DataFederationServiceOp) CreateOnePrivateEndpoint(ctx context.Context, groupID string, endpoint akov2.DataFederationPE) (*akov2.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) (*akov2.DataFederationPE, *mongodbatlas.Response, error)

func (*DataFederationServiceOp) Get

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

func (*DataFederationServiceOp) GetAllPrivateEndpoints

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

func (*DataFederationServiceOp) Update

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

type PrivateEndpointsResponse

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