atlasdatafederation

Documentation

Index

• type AtlasDataFederationReconciler
  • func NewAtlasDataFederationReconciler(mgr manager.Manager, predicates []predicate.Predicate, ...) *AtlasDataFederationReconciler
  • func (r *AtlasDataFederationReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasDataFederationReconciler) SetupWithManager(mgr ctrl.Manager, skipNameValidation bool) 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 PrivateEndpointReconciler
  • func (r *PrivateEndpointReconciler) Reconcile(ctx *workflow.Context) error
• type PrivateEndpointsResponse

Types

type AtlasDataFederationReconciler

type AtlasDataFederationReconciler struct {
	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 NewAtlasDataFederationReconciler

func NewAtlasDataFederationReconciler(
	mgr manager.Manager,
	predicates []predicate.Predicate,
	atlasProvider atlas.Provider,
	deletionProtection bool,
	logger *zap.Logger,
) *AtlasDataFederationReconciler

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, skipNameValidation bool) 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 PrivateEndpointReconciler

type PrivateEndpointReconciler struct {
	// contains filtered or unexported fields
}

func (*PrivateEndpointReconciler) Reconcile

func (r *PrivateEndpointReconciler) Reconcile(ctx *workflow.Context) error

type PrivateEndpointsResponse

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