Documentation ¶
Index ¶
- type OperatorACL
- func (o *OperatorACL) AcceptRemoteCluster(req ops.AcceptRemoteClusterRequest) (*ops.AcceptRemoteClusterResponse, error)
- func (o *OperatorACL) CheckForUpdate(key oss.SiteKey) (*loc.Locator, error)
- func (o *OperatorACL) CheckSiteLicense(ctx context.Context, key oss.SiteKey) error
- func (o *OperatorACL) DeleteOIDCConnector(ctx context.Context, key oss.SiteKey, name string) error
- func (o *OperatorACL) DeleteRole(ctx context.Context, key oss.SiteKey, name string) error
- func (o *OperatorACL) DeleteSAMLConnector(ctx context.Context, key oss.SiteKey, name string) error
- func (o *OperatorACL) DeleteTrustedCluster(ctx context.Context, req ops.DeleteTrustedClusterRequest) error
- func (o *OperatorACL) DisablePeriodicUpdates(ctx context.Context, key oss.SiteKey) error
- func (o *OperatorACL) DownloadUpdate(ctx context.Context, req ops.DownloadUpdateRequest) error
- func (o *OperatorACL) EnablePeriodicUpdates(ctx context.Context, req ops.EnablePeriodicUpdatesRequest) error
- func (o *OperatorACL) GetClusterEndpoints(key oss.SiteKey) (storage.Endpoints, error)
- func (o *OperatorACL) GetLicenseCA() ([]byte, error)
- func (o *OperatorACL) GetOIDCConnector(key oss.SiteKey, name string, withSecrets bool) (teleservices.OIDCConnector, error)
- func (o *OperatorACL) GetOIDCConnectors(key oss.SiteKey, withSecrets bool) ([]teleservices.OIDCConnector, error)
- func (o *OperatorACL) GetRole(key oss.SiteKey, name string) (teleservices.Role, error)
- func (o *OperatorACL) GetRoles(key oss.SiteKey) ([]teleservices.Role, error)
- func (o *OperatorACL) GetSAMLConnector(key oss.SiteKey, name string, withSecrets bool) (teleservices.SAMLConnector, error)
- func (o *OperatorACL) GetSAMLConnectors(key oss.SiteKey, withSecrets bool) ([]teleservices.SAMLConnector, error)
- func (o *OperatorACL) GetTrustedCluster(key oss.SiteKey, name string) (storage.TrustedCluster, error)
- func (o *OperatorACL) GetTrustedClusters(key oss.SiteKey) ([]storage.TrustedCluster, error)
- func (o *OperatorACL) NewLicense(ctx context.Context, req ops.NewLicenseRequest) (string, error)
- func (o *OperatorACL) PeriodicUpdatesStatus(key oss.SiteKey) (*ops.PeriodicUpdatesStatusResponse, error)
- func (o *OperatorACL) RegisterAgent(req ops.RegisterAgentRequest) (*ops.RegisterAgentResponse, error)
- func (o *OperatorACL) RemoveRemoteCluster(req ops.RemoveRemoteClusterRequest) error
- func (o *OperatorACL) RequestClusterCopy(req ops.ClusterCopyRequest) error
- func (o *OperatorACL) StartPeriodicUpdates(key oss.SiteKey) error
- func (o *OperatorACL) StopPeriodicUpdates(key oss.SiteKey) error
- func (o *OperatorACL) UpdateClusterEndpoints(ctx context.Context, key oss.SiteKey, endpoints storage.Endpoints) error
- func (o *OperatorACL) UpdateLicense(ctx context.Context, req ops.UpdateLicenseRequest) error
- func (o *OperatorACL) UpsertOIDCConnector(ctx context.Context, key oss.SiteKey, connector teleservices.OIDCConnector) error
- func (o *OperatorACL) UpsertRole(ctx context.Context, key oss.SiteKey, role teleservices.Role) error
- func (o *OperatorACL) UpsertSAMLConnector(ctx context.Context, key oss.SiteKey, connector teleservices.SAMLConnector) error
- func (o *OperatorACL) UpsertTrustedCluster(ctx context.Context, key oss.SiteKey, cluster storage.TrustedCluster) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OperatorACL ¶
type OperatorACL struct { // OperatorACL is the wrapped open-source ACL operator *oss.OperatorACL // contains filtered or unexported fields }
OperatorACL extends ACL operator from open-source
func OperatorWithACL ¶
func OperatorWithACL(operatorACL *oss.OperatorACL, operator ops.Operator) *OperatorACL
OperatorWithACL returns a new enterprise ACL operator
func (*OperatorACL) AcceptRemoteCluster ¶
func (o *OperatorACL) AcceptRemoteCluster(req ops.AcceptRemoteClusterRequest) (*ops.AcceptRemoteClusterResponse, error)
AcceptRemoteCluster defines the handshake between a remote cluster and this Ops Center
func (*OperatorACL) CheckForUpdate ¶
CheckForUpdate checks with remote OpsCenter if there is a newer version of the installed application
func (*OperatorACL) CheckSiteLicense ¶
CheckSiteLicense makes sure the license installed on cluster is correct
func (*OperatorACL) DeleteOIDCConnector ¶
DeleteOIDCConnector deletes an OIDC connector by name
func (*OperatorACL) DeleteRole ¶
DeleteRole deletes a role by name
func (*OperatorACL) DeleteSAMLConnector ¶
DeleteSAMLConnector deletes a SAML connector by name
func (*OperatorACL) DeleteTrustedCluster ¶
func (o *OperatorACL) DeleteTrustedCluster(ctx context.Context, req ops.DeleteTrustedClusterRequest) error
DeleteTrustedCluster deletes a trusted cluster by name
func (*OperatorACL) DisablePeriodicUpdates ¶
DisablePeriodicUpdates turns periodic updates for the cluster off and stops the update fetch loop if it's running
func (*OperatorACL) DownloadUpdate ¶
func (o *OperatorACL) DownloadUpdate(ctx context.Context, req ops.DownloadUpdateRequest) error
DownloadUpdate downloads the provided application version from remote Ops Center
func (*OperatorACL) EnablePeriodicUpdates ¶
func (o *OperatorACL) EnablePeriodicUpdates(ctx context.Context, req ops.EnablePeriodicUpdatesRequest) error
EnablePeriodicUpdates turns periodic updates for the cluster on or updates the interval
func (*OperatorACL) GetClusterEndpoints ¶
GetClusterEndpoints returns the cluster management endpoints such as control panel advertise address and agents advertise address
func (*OperatorACL) GetLicenseCA ¶
func (o *OperatorACL) GetLicenseCA() ([]byte, error)
GetLicenseCA returns CA certificate Ops Center uses to sign licenses
func (*OperatorACL) GetOIDCConnector ¶
func (o *OperatorACL) GetOIDCConnector(key oss.SiteKey, name string, withSecrets bool) (teleservices.OIDCConnector, error)
GetOIDCConnector returns an OIDC connector by name
Returned connector exclude client secret unless withSecrets is true.
func (*OperatorACL) GetOIDCConnectors ¶
func (o *OperatorACL) GetOIDCConnectors(key oss.SiteKey, withSecrets bool) ([]teleservices.OIDCConnector, error)
GetOIDCConnectors returns all OIDC connectors
Returned connectors exclude client secret unless withSecrets is true.
func (*OperatorACL) GetRole ¶
func (o *OperatorACL) GetRole(key oss.SiteKey, name string) (teleservices.Role, error)
GetRole returns a role by name
func (*OperatorACL) GetRoles ¶
func (o *OperatorACL) GetRoles(key oss.SiteKey) ([]teleservices.Role, error)
GetRoles returns all roles
func (*OperatorACL) GetSAMLConnector ¶
func (o *OperatorACL) GetSAMLConnector(key oss.SiteKey, name string, withSecrets bool) (teleservices.SAMLConnector, error)
GetSAMLConnector returns a SAML connector by name
Returned connector excludes private signing key unless withSecrets is true.
func (*OperatorACL) GetSAMLConnectors ¶
func (o *OperatorACL) GetSAMLConnectors(key oss.SiteKey, withSecrets bool) ([]teleservices.SAMLConnector, error)
GetSAMLConnectors returns all SAML connectors
Returned connectors exclude private signing keys unless withSecrets is true.
func (*OperatorACL) GetTrustedCluster ¶
func (o *OperatorACL) GetTrustedCluster(key oss.SiteKey, name string) (storage.TrustedCluster, error)
GetTrustedCluster returns trusted cluster by name
func (*OperatorACL) GetTrustedClusters ¶
func (o *OperatorACL) GetTrustedClusters(key oss.SiteKey) ([]storage.TrustedCluster, error)
GetTrustedClusters returns a list of configured trusted clusters
func (*OperatorACL) NewLicense ¶
func (o *OperatorACL) NewLicense(ctx context.Context, req ops.NewLicenseRequest) (string, error)
NewLicense generates a new license signed with this Ops Center CA
func (*OperatorACL) PeriodicUpdatesStatus ¶
func (o *OperatorACL) PeriodicUpdatesStatus(key oss.SiteKey) (*ops.PeriodicUpdatesStatusResponse, error)
PeriodicUpdatesStatus returns the status of periodic updates for the cluster
func (*OperatorACL) RegisterAgent ¶
func (o *OperatorACL) RegisterAgent(req ops.RegisterAgentRequest) (*ops.RegisterAgentResponse, error)
RegisterAgent registers an install agent
func (*OperatorACL) RemoveRemoteCluster ¶
func (o *OperatorACL) RemoveRemoteCluster(req ops.RemoveRemoteClusterRequest) error
RemoveRemoteCluster removes the cluster entry specified in the request
func (*OperatorACL) RequestClusterCopy ¶
func (o *OperatorACL) RequestClusterCopy(req ops.ClusterCopyRequest) error
RequestClusterCopy replicates the cluster specified in the provided request and its data from the remote Ops Center
func (*OperatorACL) StartPeriodicUpdates ¶
func (o *OperatorACL) StartPeriodicUpdates(key oss.SiteKey) error
StartPeriodicUpdates starts periodic updates check
func (*OperatorACL) StopPeriodicUpdates ¶
func (o *OperatorACL) StopPeriodicUpdates(key oss.SiteKey) error
StopPeriodicUpdates stops periodic updates check without disabling it
func (*OperatorACL) UpdateClusterEndpoints ¶
func (o *OperatorACL) UpdateClusterEndpoints(ctx context.Context, key oss.SiteKey, endpoints storage.Endpoints) error
UpdateClusterEndpoints updates the cluster management endpoints
func (*OperatorACL) UpdateLicense ¶
func (o *OperatorACL) UpdateLicense(ctx context.Context, req ops.UpdateLicenseRequest) error
UpdateLicense updates license installed on cluster and runs a respective app hook
func (*OperatorACL) UpsertOIDCConnector ¶
func (o *OperatorACL) UpsertOIDCConnector(ctx context.Context, key oss.SiteKey, connector teleservices.OIDCConnector) error
UpsertOIDCConnector creates or updates an OIDC connector
func (*OperatorACL) UpsertRole ¶
func (o *OperatorACL) UpsertRole(ctx context.Context, key oss.SiteKey, role teleservices.Role) error
UpsertRole creates a new role
func (*OperatorACL) UpsertSAMLConnector ¶
func (o *OperatorACL) UpsertSAMLConnector(ctx context.Context, key oss.SiteKey, connector teleservices.SAMLConnector) error
UpsertSAMLConnector creates or updates a SAML connector
func (*OperatorACL) UpsertTrustedCluster ¶
func (o *OperatorACL) UpsertTrustedCluster(ctx context.Context, key oss.SiteKey, cluster storage.TrustedCluster) error
UpsertTrustedCluster creates or updates a trusted cluster