model

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 8, 2019 License: Apache-2.0 Imports: 13 Imported by: 18

Documentation

Index

Constants

View Source 
const (
	// InstallationAffinityIsolated means that no peer installations are allowed in the same cluster.
	InstallationAffinityIsolated = "isolated"
	// InstallationAffinityMultiTenant means peer installations are allowed in the same cluster.
	InstallationAffinityMultiTenant = "multitenant"
)
View Source 
const (
	// ClusterStateCreationRequested is a cluster in the process of being created.
	ClusterStateCreationRequested = "creation-requested"
	// ClusterStateCreationFailed is a cluster that failed creation.
	ClusterStateCreationFailed = "creation-failed"
	// ClusterStateProvisioningRequested is a cluster in the process of being
	// provisioned with operators.
	ClusterStateProvisioningRequested = "provisioning-requested"
	// ClusterStateProvisioningFailed is a cluster that failed provisioning.
	ClusterStateProvisioningFailed = "provisioning-failed"
	// ClusterStateDeletionRequested is a cluster in the process of being deleted.
	ClusterStateDeletionRequested = "deletion-requested"
	// ClusterStateDeletionFailed is a cluster that failed deletion.
	ClusterStateDeletionFailed = "deletion-failed"
	// ClusterStateDeleted is a cluster that has been deleted
	ClusterStateDeleted = "deleted"
	// ClusterStateUpgradeRequested is a cluster in the process of upgrading.
	ClusterStateUpgradeRequested = "upgrade-requested"
	// ClusterStateUpgradeFailed is a cluster that failed to upgrade.
	ClusterStateUpgradeFailed = "upgrade-failed"
	// ClusterStateStable is a cluster in a stable state and undergoing no changes.
	ClusterStateStable = "stable"
)
View Source 
const (
	// ClusterInstallationStateCreationRequested is a cluster installation in the process of being created.
	ClusterInstallationStateCreationRequested = "creation-requested"
	// ClusterInstallationStateCreationFailed is a cluster installation that failed creation.
	ClusterInstallationStateCreationFailed = "creation-failed"
	// ClusterInstallationStateDeletionRequested is a cluster installation in the process of being deleted.
	ClusterInstallationStateDeletionRequested = "deletion-requested"
	// ClusterInstallationStateDeletionFailed is a cluster installation that failed deletion.
	ClusterInstallationStateDeletionFailed = "deletion-failed"
	// ClusterInstallationStateDeleted is a cluster installation that has been deleted
	ClusterInstallationStateDeleted = "deleted"
	// ClusterInstallationStateReconciling is a cluster installation that in undergoing changes and is not yet stable.
	ClusterInstallationStateReconciling = "reconciling"
	// ClusterInstallationStateStable is a cluster installation in a stable state and undergoing no changes.
	ClusterInstallationStateStable = "stable"
)
View Source 
const (
	// InstallationStateCreationRequested is an installation in the process of being created.
	InstallationStateCreationRequested = "creation-requested"
	// InstallationStateCreationDNS is an installation in the process having configuring DNS.
	InstallationStateCreationDNS = "creation-configuring-dns"
	// InstallationStateCreationFailed is an installation that failed creation.
	InstallationStateCreationFailed = "creation-failed"
	// InstallationStateCreationNoCompatibleClusters is an installation that
	// can't be fully created because there are no compatible clusters.
	InstallationStateCreationNoCompatibleClusters = "creation-no-compatible-clusters"
	// InstallationStateDeletionRequested is an installation to be deleted.
	InstallationStateDeletionRequested = "deletion-requested"
	// InstallationStateDeletionInProgress is an installation being deleted.
	InstallationStateDeletionInProgress = "deletion-in-progress"
	// InstallationStateDeletionFailed is an installation that failed deletion.
	InstallationStateDeletionFailed = "deletion-failed"
	// InstallationStateDeleted is an installation that has been deleted
	InstallationStateDeleted = "deleted"
	// InstallationStateUpgradeRequested is an installation that is about to undergo a version change.
	InstallationStateUpgradeRequested = "upgrade-requested"
	// InstallationStateUpgradeInProgress is an installation that is undergoing a version change.
	InstallationStateUpgradeInProgress = "upgrade-in-progress"
	// InstallationStateUpgradeFailed is an installation that failed to change versions.
	InstallationStateUpgradeFailed = "upgrade-failed"
	// InstallationStateStable is an installation in a stable state and undergoing no changes.
	InstallationStateStable = "stable"

	// InstallationDefaultSize is the default size for an installation.
	InstallationDefaultSize = mmv1alpha1.Size100String
)
View Source 
const (
	// SizeAlef500 is the first definition of a cluster supporting 500 users.
	SizeAlef500 = "SizeAlef500"
	// SizeAlef1000 is the second definition of a cluster supporting 1000 users.
	SizeAlef1000 = "SizeAlef1000"
)
View Source 
const (
	// AllPerPage signals the store to return all results, avoid pagination of any kind.
	AllPerPage = -1
)
View Source 
const (
	// ProviderAWS is the cloud provider AWS.
	ProviderAWS = "aws"
)

Variables

This section is empty.

Functions

func CheckProvider 

func CheckProvider(provider string) (string, error)

CheckProvider normalizes the given provider, returning an error if invalid.

func ClusterInstallationConfigFromReader 

func ClusterInstallationConfigFromReader(reader io.Reader) (map[string]interface{}, error)

ClusterInstallationConfigFromReader decodes a json-encoded config from the config io.Reader.

func IsSupportedAffinity 

func IsSupportedAffinity(affinity string) bool

IsSupportedAffinity returns true if the given affinity string is supported.

func IsSupportedSize 

func IsSupportedSize(size string) bool

IsSupportedSize returns true if the given size string is supported.

func NewID 

func NewID() string

NewID is a globally unique identifier. It is a [A-Z0-9] string 26 characters long. It is a UUID version 4 Guid that is zbased32 encoded with the padding stripped off.

Types

type AWSMetadata 

type AWSMetadata struct {
	Zones []string
}

AWSMetadata is the provider metadata stored in a model.Cluster.

func NewAWSMetadata 

func NewAWSMetadata(providerMetadata []byte) (*AWSMetadata, error)

NewAWSMetadata creates an instance of AWSMetadata given the raw provider metadata.

type Client 

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

Client is the programmatic interface to the provisioning server API.

func NewClient 

func NewClient(address string) *Client

NewClient creates a client to the provisioning server at the given address.

func (*Client) CreateCluster 

func (c *Client) CreateCluster(request *CreateClusterRequest) (*Cluster, error)

CreateCluster requests the creation of a cluster from the configured provisioning server.

func (*Client) CreateGroup 

func (c *Client) CreateGroup(request *CreateGroupRequest) (*Group, error)

CreateGroup requests the creation of a group from the configured provisioning server.

func (*Client) CreateInstallation 

func (c *Client) CreateInstallation(request *CreateInstallationRequest) (*Installation, error)

CreateInstallation requests the creation of a installation from the configured provisioning server.

func (*Client) DeleteCluster 

func (c *Client) DeleteCluster(clusterID string) error

DeleteCluster deletes the given cluster and all resources contained therein.

func (*Client) DeleteGroup 

func (c *Client) DeleteGroup(groupID string) error

DeleteGroup deletes the given group and all resources contained therein.

func (*Client) DeleteInstallation 

func (c *Client) DeleteInstallation(installationID string) error

DeleteInstallation deletes the given installation and all resources contained therein.

func (*Client) GetCluster 

func (c *Client) GetCluster(clusterID string) (*Cluster, error)

GetCluster fetches the specified cluster from the configured provisioning server.

func (*Client) GetClusterInstallation 

func (c *Client) GetClusterInstallation(clusterInstallationID string) (*ClusterInstallation, error)

GetClusterInstallation fetches the specified cluster installation from the configured provisioning server.

func (*Client) GetClusterInstallationConfig 

func (c *Client) GetClusterInstallationConfig(clusterInstallationID string) (map[string]interface{}, error)

GetClusterInstallationConfig fetches the specified cluster installation's Mattermost config.

func (*Client) GetClusterInstallations 

func (c *Client) GetClusterInstallations(request *GetClusterInstallationsRequest) ([]*ClusterInstallation, error)

GetClusterInstallations fetches the list of cluster installations from the configured provisioning server.

func (*Client) GetClusters 

func (c *Client) GetClusters(request *GetClustersRequest) ([]*Cluster, error)

GetClusters fetches the list of clusters from the configured provisioning server.

func (*Client) GetGroup 

func (c *Client) GetGroup(groupID string) (*Group, error)

GetGroup fetches the specified group from the configured provisioning server.

func (*Client) GetGroups 

func (c *Client) GetGroups(request *GetGroupsRequest) ([]*Group, error)

GetGroups fetches the list of groups from the configured provisioning server.

func (*Client) GetInstallation 

func (c *Client) GetInstallation(installationID string) (*Installation, error)

GetInstallation fetches the specified installation from the configured provisioning server.

func (*Client) GetInstallations 

func (c *Client) GetInstallations(request *GetInstallationsRequest) ([]*Installation, error)

GetInstallations fetches the list of installations from the configured provisioning server.

func (*Client) JoinGroup 

func (c *Client) JoinGroup(groupID, installationID string) error

JoinGroup joins an installation to the given group, leaving any existing group.

func (*Client) LeaveGroup 

func (c *Client) LeaveGroup(installationID string) error

LeaveGroup removes an installation from its group, if any.

func (*Client) ProvisionCluster 

func (c *Client) ProvisionCluster(clusterID string) error

ProvisionCluster provisions k8s operators on a cluster from the configured provisioning server.

func (*Client) RetryCreateCluster 

func (c *Client) RetryCreateCluster(clusterID string) error

RetryCreateCluster retries the creation of a cluster from the configured provisioning server.

func (*Client) RetryCreateInstallation 

func (c *Client) RetryCreateInstallation(installationID string) error

RetryCreateInstallation retries the creation of a installation from the configured provisioning server.

func (*Client) SetClusterInstallationConfig 

func (c *Client) SetClusterInstallationConfig(clusterInstallationID string, config map[string]interface{}) error

SetClusterInstallationConfig modifies an cluster installation's Mattermost configuration.

The operation is applied as a patch, preserving existing values if they are not specified.

func (*Client) UpdateGroup 

func (c *Client) UpdateGroup(request *PatchGroupRequest) error

UpdateGroup updates the installation group.

func (*Client) UpgradeCluster 

func (c *Client) UpgradeCluster(clusterID, version string) error

UpgradeCluster upgrades a cluster to the latest recommended production ready k8s version.

func (*Client) UpgradeInstallation 

func (c *Client) UpgradeInstallation(installationID, version, license string) error

UpgradeInstallation upgrades a installation to the given Mattermost version.

type Cluster 

type Cluster struct {
	ID                  string
	Provider            string
	Provisioner         string
	ProviderMetadata    []byte `json:",omitempty"`
	ProvisionerMetadata []byte `json:",omitempty"`
	AllowInstallations  bool
	Size                string
	State               string
	CreateAt            int64
	DeleteAt            int64
	LockAcquiredBy      *string
	LockAcquiredAt      int64
}

Cluster represents a Kubernetes cluster.

func ClusterFromReader 

func ClusterFromReader(reader io.Reader) (*Cluster, error)

ClusterFromReader decodes a json-encoded cluster from the given io.Reader.

func ClustersFromReader 

func ClustersFromReader(reader io.Reader) ([]*Cluster, error)

ClustersFromReader decodes a json-encoded list of clusters from the given io.Reader.

func (*Cluster) Clone 

func (c *Cluster) Clone() *Cluster

Clone returns a deep copy the cluster.

func (*Cluster) SetProviderMetadata 

func (c *Cluster) SetProviderMetadata(data interface{}) error

SetProviderMetadata is a helper method to encode an interface{} as the corresponding bytes.

func (*Cluster) SetProvisionerMetadata 

func (c *Cluster) SetProvisionerMetadata(data interface{}) error

SetProvisionerMetadata is a helper method to encode an interface{} as the corresponding bytes.

type ClusterFilter 

type ClusterFilter struct {
	Page           int
	PerPage        int
	IncludeDeleted bool
}

ClusterFilter describes the parameters used to constrain a set of clusters.

type ClusterInstallation 

type ClusterInstallation struct {
	ID             string
	ClusterID      string
	InstallationID string
	Namespace      string
	State          string
	CreateAt       int64
	DeleteAt       int64
	LockAcquiredBy *string
	LockAcquiredAt int64
}

ClusterInstallation is a single namespace within a cluster composing a potentially larger installation.

func ClusterInstallationFromReader 

func ClusterInstallationFromReader(reader io.Reader) (*ClusterInstallation, error)

ClusterInstallationFromReader decodes a json-encoded cluster installation from the given io.Reader.

func ClusterInstallationsFromReader 

func ClusterInstallationsFromReader(reader io.Reader) ([]*ClusterInstallation, error)

ClusterInstallationsFromReader decodes a json-encoded list of cluster installations from the given io.Reader.

func (*ClusterInstallation) Clone 

func (c *ClusterInstallation) Clone() *ClusterInstallation

Clone returns a deep copy the cluster installation.

type ClusterInstallationConfigRequest 

type ClusterInstallationConfigRequest map[string]interface{}

ClusterInstallationConfigRequest describes the payload for updating an cluster installation's configuration.

func NewClusterInstallationConfigRequestFromReader 

func NewClusterInstallationConfigRequestFromReader(reader io.Reader) (ClusterInstallationConfigRequest, error)

NewClusterInstallationConfigRequestFromReader will create a ClusterInstallationConfigRequest from an io.Reader with JSON data.

type ClusterInstallationFilter 

type ClusterInstallationFilter struct {
	IDs            []string
	InstallationID string
	ClusterID      string
	Page           int
	PerPage        int
	IncludeDeleted bool
}

ClusterInstallationFilter describes the parameters used to constrain a set of cluster installations.

type CreateClusterRequest 

type CreateClusterRequest struct {
	Provider string
	Size     string
	Zones    []string
}

CreateClusterRequest specifies the parameters for a new cluster.

func NewCreateClusterRequestFromReader 

func NewCreateClusterRequestFromReader(reader io.Reader) (*CreateClusterRequest, error)

NewCreateClusterRequestFromReader will create a CreateClusterRequest from an io.Reader with JSON data.

type CreateGroupRequest 

type CreateGroupRequest struct {
	Name        string
	Description string
	Version     string
}

CreateGroupRequest specifies the parameters for a new group.

func NewCreateGroupRequestFromReader 

func NewCreateGroupRequestFromReader(reader io.Reader) (*CreateGroupRequest, error)

NewCreateGroupRequestFromReader will create a CreateGroupRequest from an io.Reader with JSON data.

type CreateInstallationRequest 

type CreateInstallationRequest struct {
	OwnerID  string
	Version  string
	DNS      string
	License  string
	Size     string
	Affinity string
}

CreateInstallationRequest specifies the parameters for a new installation.

func NewCreateInstallationRequestFromReader 

func NewCreateInstallationRequestFromReader(reader io.Reader) (*CreateInstallationRequest, error)

NewCreateInstallationRequestFromReader will create a CreateInstallationRequest from an io.Reader with JSON data.

type GetClusterInstallationsRequest 

type GetClusterInstallationsRequest struct {
	ClusterID      string
	InstallationID string
	Page           int
	PerPage        int
	IncludeDeleted bool
}

GetClusterInstallationsRequest describes the parameters to request a list of cluster installations.

func (*GetClusterInstallationsRequest) ApplyToURL 

func (request *GetClusterInstallationsRequest) ApplyToURL(u *url.URL)

ApplyToURL modifies the given url to include query string parameters for the request.

type GetClustersRequest 

type GetClustersRequest struct {
	Page           int
	PerPage        int
	IncludeDeleted bool
}

GetClustersRequest describes the parameters to request a list of clusters.

func (*GetClustersRequest) ApplyToURL 

func (request *GetClustersRequest) ApplyToURL(u *url.URL)

ApplyToURL modifies the given url to include query string parameters for the request.

type GetGroupsRequest 

type GetGroupsRequest struct {
	Page           int
	PerPage        int
	IncludeDeleted bool
}

GetGroupsRequest describes the parameters to request a list of groups.

func (*GetGroupsRequest) ApplyToURL 

func (request *GetGroupsRequest) ApplyToURL(u *url.URL)

ApplyToURL modifies the given url to include query string parameters for the request.

type GetInstallationsRequest 

type GetInstallationsRequest struct {
	OwnerID        string
	Page           int
	PerPage        int
	IncludeDeleted bool
}

GetInstallationsRequest describes the parameters to request a list of installations.

func (*GetInstallationsRequest) ApplyToURL 

func (request *GetInstallationsRequest) ApplyToURL(u *url.URL)

ApplyToURL modifies the given url to include query string parameters for the request.

type Group 

type Group struct {
	ID          string
	Name        string
	Description string
	Version     string
	CreateAt    int64
	DeleteAt    int64
}

Group represents a group of Mattermost installations.

func GroupFromReader 

func GroupFromReader(reader io.Reader) (*Group, error)

GroupFromReader decodes a json-encoded group from the given io.Reader.

func GroupsFromReader 

func GroupsFromReader(reader io.Reader) ([]*Group, error)

GroupsFromReader decodes a json-encoded list of groups from the given io.Reader.

func (*Group) Clone 

func (c *Group) Clone() *Group

Clone returns a deep copy the group.

type GroupFilter 

type GroupFilter struct {
	Page           int
	PerPage        int
	IncludeDeleted bool
}

GroupFilter describes the parameters used to constrain a set of groups.

type Installation 

type Installation struct {
	ID             string
	OwnerID        string
	Version        string
	DNS            string
	License        string
	Size           string
	Affinity       string
	GroupID        *string
	State          string
	CreateAt       int64
	DeleteAt       int64
	LockAcquiredBy *string
	LockAcquiredAt int64
}

Installation represents a Mattermost installation.

func InstallationFromReader 

func InstallationFromReader(reader io.Reader) (*Installation, error)

InstallationFromReader decodes a json-encoded installation from the given io.Reader.

func InstallationsFromReader 

func InstallationsFromReader(reader io.Reader) ([]*Installation, error)

InstallationsFromReader decodes a json-encoded list of installations from the given io.Reader.

func (*Installation) Clone 

func (c *Installation) Clone() *Installation

Clone returns a deep copy the installation.

type InstallationFilter 

type InstallationFilter struct {
	OwnerID        string
	Page           int
	PerPage        int
	IncludeDeleted bool
}

InstallationFilter describes the parameters used to constrain a set of installations.

type KopsMetadata 

type KopsMetadata struct {
	Name string
}

KopsMetadata is the provisioner metadata stored in a model.Cluster.

func NewKopsMetadata 

func NewKopsMetadata(provisionerMetadata []byte) (*KopsMetadata, error)

NewKopsMetadata creates an instance of KopsMetadata given the raw provisioner metadata.

type PatchGroupRequest 

type PatchGroupRequest struct {
	ID          string
	Name        *string
	Description *string
	Version     *string
}

PatchGroupRequest specifies the parameters for an updated group.

func NewPatchGroupRequestFromReader 

func NewPatchGroupRequestFromReader(reader io.Reader) (*PatchGroupRequest, error)

NewPatchGroupRequestFromReader will create a PatchGroupRequest from an io.Reader with JSON data.

func (*PatchGroupRequest) Apply 

func (p *PatchGroupRequest) Apply(group *Group) bool

Apply applies the patch to the given group.

type UpgradeInstallationRequest 

type UpgradeInstallationRequest struct {
	Version string
	License string
}

UpgradeInstallationRequest specifies the parameters for an upgraded installation.

func NewUpgradeInstallationRequestFromReader 

func NewUpgradeInstallationRequestFromReader(reader io.Reader) (*UpgradeInstallationRequest, error)

NewUpgradeInstallationRequestFromReader will create a UpgradeInstallationRequest from an io.Reader with JSON data.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.