datafederation

Documentation

Index

• Variables
• func MapDatafederationPrivateEndpoints(projectID string, df *akov2.AtlasDataFederation, ...) (map[string]*DataFederationPrivateEndpoint, error)
• type AtlasDataFederationService
  • func NewAtlasDataFederationService(ctx context.Context, provider atlas.Provider, secretRef *types.NamespacedName, ...) (*AtlasDataFederationService, error)
  • func (dfs *AtlasDataFederationService) Create(ctx context.Context, df *DataFederation) error
  • func (dfs *AtlasDataFederationService) Delete(ctx context.Context, projectID, name string) error
  • func (dfs *AtlasDataFederationService) Get(ctx context.Context, projectID, name string) (*DataFederation, error)
  • func (dfs *AtlasDataFederationService) Update(ctx context.Context, df *DataFederation) error
• type DataFederation
  • func NewDataFederation(spec *akov2.DataFederationSpec, projectID string, hostnames []string) (*DataFederation, error)
  • func (df *DataFederation) SpecEqualsTo(target *DataFederation) bool
• type DataFederationPrivateEndpoint
• type DataFederationService
• type DatafederationPrivateEndpointEntry
  • func NewDataFederationPrivateEndpointEntry(projectID string, pe *akov2.DataFederationPE) *DatafederationPrivateEndpointEntry
  • func (e *DatafederationPrivateEndpointEntry) EqualsTo(target *DatafederationPrivateEndpointEntry) bool
• type DatafederationPrivateEndpointService
• type DatafederationPrivateEndpoints
  • func NewDatafederationPrivateEndpointService(ctx context.Context, provider atlas.Provider, secretRef *types.NamespacedName, ...) (*DatafederationPrivateEndpoints, error)
  • func (d *DatafederationPrivateEndpoints) Create(ctx context.Context, aep *DatafederationPrivateEndpointEntry) error
  • func (d *DatafederationPrivateEndpoints) Delete(ctx context.Context, aep *DatafederationPrivateEndpointEntry) error
  • func (d *DatafederationPrivateEndpoints) List(ctx context.Context, projectID string) ([]*DatafederationPrivateEndpointEntry, error)

Variables

var (
	ErrorNotFound = errors.New("data federation not found")
)

Functions

func MapDatafederationPrivateEndpoints

func MapDatafederationPrivateEndpoints(projectID string, df *akov2.AtlasDataFederation, atlasEndpoints []*DatafederationPrivateEndpointEntry) (map[string]*DataFederationPrivateEndpoint, error)

Types

type AtlasDataFederationService

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

func NewAtlasDataFederationService

func NewAtlasDataFederationService(ctx context.Context, provider atlas.Provider, secretRef *types.NamespacedName, log *zap.SugaredLogger) (*AtlasDataFederationService, error)

func (*AtlasDataFederationService) Create

func (dfs *AtlasDataFederationService) Create(ctx context.Context, df *DataFederation) error

func (*AtlasDataFederationService) Delete

func (dfs *AtlasDataFederationService) Delete(ctx context.Context, projectID, name string) error

func (*AtlasDataFederationService) Get

func (dfs *AtlasDataFederationService) Get(ctx context.Context, projectID, name string) (*DataFederation, error)

func (*AtlasDataFederationService) Update

func (dfs *AtlasDataFederationService) Update(ctx context.Context, df *DataFederation) error

type DataFederation

type DataFederation struct {
	*akov2.DataFederationSpec
	ProjectID string
	Hostnames []string
}

func NewDataFederation

func NewDataFederation(spec *akov2.DataFederationSpec, projectID string, hostnames []string) (*DataFederation, error)

func (*DataFederation) SpecEqualsTo

func (df *DataFederation) SpecEqualsTo(target *DataFederation) bool

SpecEqualsTo returns true if the spec of the data federation instance semantically equals to the given one. Note: it assumes the spec is already normalized.

type DataFederationPrivateEndpoint

type DataFederationPrivateEndpoint struct {
	AKO, Atlas, LastApplied *DatafederationPrivateEndpointEntry
}

type DataFederationService

type DataFederationService interface {
	Get(ctx context.Context, projectID, name string) (*DataFederation, error)
	Create(ctx context.Context, df *DataFederation) error
	Update(ctx context.Context, df *DataFederation) error
	Delete(ctx context.Context, projectID, name string) error
}

type DatafederationPrivateEndpointEntry

type DatafederationPrivateEndpointEntry struct {
	*akov2.DataFederationPE
	ProjectID string
}

func NewDataFederationPrivateEndpointEntry

func NewDataFederationPrivateEndpointEntry(projectID string, pe *akov2.DataFederationPE) *DatafederationPrivateEndpointEntry

func (*DatafederationPrivateEndpointEntry) EqualsTo

func (e *DatafederationPrivateEndpointEntry) EqualsTo(target *DatafederationPrivateEndpointEntry) bool

type DatafederationPrivateEndpointService

type DatafederationPrivateEndpointService interface {
	List(ctx context.Context, projectID string) ([]*DatafederationPrivateEndpointEntry, error)
	Create(context.Context, *DatafederationPrivateEndpointEntry) error
	Delete(context.Context, *DatafederationPrivateEndpointEntry) error
}

type DatafederationPrivateEndpoints

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

func NewDatafederationPrivateEndpointService

func NewDatafederationPrivateEndpointService(ctx context.Context, provider atlas.Provider, secretRef *types.NamespacedName, log *zap.SugaredLogger) (*DatafederationPrivateEndpoints, error)

func (*DatafederationPrivateEndpoints) Create

func (d *DatafederationPrivateEndpoints) Create(ctx context.Context, aep *DatafederationPrivateEndpointEntry) error

func (*DatafederationPrivateEndpoints) Delete

func (d *DatafederationPrivateEndpoints) Delete(ctx context.Context, aep *DatafederationPrivateEndpointEntry) error

func (*DatafederationPrivateEndpoints) List

func (d *DatafederationPrivateEndpoints) List(ctx context.Context, projectID string) ([]*DatafederationPrivateEndpointEntry, error)