model

Apr 30, 2024

Changes in this version

+ const PgBouncerDefaultDefaultPoolSize

Apr 24, 2024

Changes in this version

+ const ArgocdApiToken

+ const ArgocdServerApi

+ const PgBouncerDefaultMaxClientConnections

+ const PgBouncerDefaultMaxDatabaseConnectionsPerPool

+ const PgBouncerDefaultMinPoolSize

+ const PgBouncerDefaultPoolSize

+ const PgBouncerDefaultReservePoolSize

+ const PgBouncerDefaultServerIdleTimeout

+ const PgBouncerDefaultServerLifetime

+ const PgBouncerDefaultServerResetQueryAlways

+ func GetArgocdApiToken() string

+ func GetArgocdServerApi() string

+ func SetArgocdApiToken(val string)

+ func SetArgocdServerApi(val string)

type Cluster

+ PgBouncerConfig *PgBouncerConfig

type CreateClusterRequest

+ PgBouncerConfig *PgBouncerConfig

type KopsInstanceGroupMetadata

+ AMI string

+ type PatchPgBouncerConfig struct

+ DefaultPoolSize *int64

+ MaxClientConnections *int64

+ MaxDatabaseConnectionsPerPool *int64

+ MinPoolSize *int64

+ ReservePoolSize *int64

+ ServerIdleTimeout *int64

+ ServerLifetime *int64

+ ServerResetQueryAlways *int64

+ func (c *PatchPgBouncerConfig) Validate() error

+ type PgBouncerConfig struct

+ DefaultPoolSize int64

+ MaxClientConnections int64

+ MaxDatabaseConnectionsPerPool int64

+ MinPoolSize int64

+ ReservePoolSize int64

+ ServerIdleTimeout int64

+ ServerLifetime int64

+ ServerResetQueryAlways int64

+ func NewDefaultPgBouncerConfig() *PgBouncerConfig

+ func NewPgBouncerConfig(minPoolSize, defaultPoolSize, reservePoolSize, maxClientConnections, ... int64) *PgBouncerConfig

+ func (c *PgBouncerConfig) ApplyPatch(p *PatchPgBouncerConfig)

+ func (c *PgBouncerConfig) FromJSONString(PgBouncerConfigStr string) (*PgBouncerConfig, error)

+ func (c *PgBouncerConfig) Scan(src interface{}) error

+ func (c *PgBouncerConfig) SetDefaults()

+ func (c *PgBouncerConfig) Validate() error

+ func (c *PgBouncerConfig) Value() (driver.Value, error)

type ProvisionClusterRequest

+ PgBouncerConfig *PatchPgBouncerConfig

+ func (request *ProvisionClusterRequest) Validate() error

Mar 4, 2024

Changes in this version

+ const GitOpsRepoPath

+ func GetGitopsRepoPath() string

+ func GetGitopsRepoURL() string

+ func SetGitopsRepoPath(gitopsPath string)

+ func SetGitopsRepoURL(gitopsUrl string)

type Cluster

+ func (c *Cluster) SetManagedByArgocd(clusterValues map[string]string)

type CreateClusterRequest

+ ArgocdClusterRegister map[string]string

type ProvisionClusterRequest

+ ArgocdClusterRegister map[string]string

+ type UtilityArgocdClusterRegister struct

+ ClusterType string

+ Registered bool

type UtilityMetadata

+ ArgocdClusterRegister UtilityArgocdClusterRegister

+ ManagedByArgocd bool

Jan 15, 2024

Changes in this version

type IngressAnnotations

+ CustomHttpErrors []string

Dec 1, 2023

Changes in this version

+ func IsValidKMSARN(s string) bool

type AllowedIPRanges

+ func (a *AllowedIPRanges) AllRulesAreDisabled() bool

type Client

+ func (c *Client) DeleteInstallationDNS(installationID, installationDNSID string) (*InstallationDTO, error)

type CreateClusterRequest

+ KmsKeyId string

type GetInstallationsRequest

+ DeletionLocked *bool

type Headers

+ func (wh Headers) Count() int

+ type IngressAnnotations struct

+ ConfigurationSnippet string

+ ProxyBodySize string

+ ProxyBuffering string

+ ProxyMaxTempFileSize string

+ ProxyReadTimeout string

+ ProxySendTimeout string

+ SSLRedirect string

+ ServerSnippets string

+ TLSACME string

+ WhitelistSourceRange []string

+ func (ia *IngressAnnotations) SetDefaults()

+ func (ia *IngressAnnotations) SetHibernatingDefaults()

+ func (ia *IngressAnnotations) ToMap() map[string]string

type InstallationDNS

+ func (dns *InstallationDNS) IsDeleted() bool

type InstallationFilter

+ DeletionLocked *bool

type KopsMetadata

+ KmsKeyId string

+ func (km *KopsMetadata) GetKopsMasterResizeSetActionsFromChanges(changes KopsInstanceGroupMetadata, igName string) []string

+ func (km *KopsMetadata) GetMasterNodesResizeChanges() KopsInstanceGroupsMetadata

type KopsMetadataRequestedState

+ KmsKeyId string

type PatchClusterSizeRequest

+ MasterInstanceType *string

type PatchUpgradeClusterRequest

+ KmsKeyId *string

type ProvisionerMetadata

+ KmsKeyId string

Oct 5, 2023

Changes in this version

+ func IsIPRangeValid(ipRange string) bool

+ type AllowedIPRange struct

+ CIDRBlock string

+ Description string

+ Enabled bool

+ OwnerID string

+ type AllowedIPRanges []AllowedIPRange

+ func (a *AllowedIPRanges) AreValid() bool

+ func (a *AllowedIPRanges) Contains(IP string) bool

+ func (a *AllowedIPRanges) FromJSONString(allowedIPRangesStr string) (*AllowedIPRanges, error)

+ func (a *AllowedIPRanges) Scan(src interface{}) error

+ func (a *AllowedIPRanges) ToAnnotationString() string

+ func (a *AllowedIPRanges) ToString() string

+ func (a AllowedIPRanges) Value() (driver.Value, error)

type PatchInstallationRequest

+ func (p *PatchInstallationRequest) MergeNewIngressSourceRangesWithExisting(installation *Installation) (*AllowedIPRanges, error)

Sep 11, 2023

Changes in this version

type Client

+ func (c *Client) DeleteLogicalDatabase(logicalDatabaseID string) error

type GetInstallationsRequest

+ AllowedIPRanges string

+ OverrideIPRanges bool

type Installation

+ AllowedIPRanges string

type PatchInstallationRequest

+ AllowedIPRanges *string

+ OverrideIPRanges *bool

Jul 17, 2023

Changes in this version

type Client

+ func (c *Client) LockDeletionLockForInstallation(installationID string) error

+ func (c *Client) UnlockDeletionLockForInstallation(installationID string) error

type CreateInstallationRequest

+ DeletionLocked bool

type Installation

+ DeletionLocked bool

Jun 12, 2023

Changes in this version

+ type DeletionPendingReport struct

+ Cutoffs []*DeletionPendingTimeCutoff

+ Overflow int

+ func (dpr *DeletionPendingReport) Count(millis int64)

+ func (dpr *DeletionPendingReport) NewCutoff(name string, cutoffTime time.Time)

+ type DeletionPendingTimeCutoff struct

+ Count int

+ Millis int64

+ Name string

Jun 5, 2023

Changes in this version

+ const ClusterStateNodegroupsDeletionFailed

+ const ClusterStateNodegroupsDeletionRequested

+ const UnmanagedUtilityVersion

+ func UtilityIsUnmanaged(desired *HelmUtilityVersion, actual *HelmUtilityVersion) bool

type Client

+ func (c *Client) DeleteNodegroup(clusterID string, nodegroup string) (*ClusterDTO, error)

type EKSMetadata

+ func (em *EKSMetadata) ApplyNodegroupDeleteRequest(nodegroup string)

+ func (em *EKSMetadata) ValidateNodegroupDeleteRequest(nodegroup string) error

May 4, 2023

Changes in this version

+ const ClusterStateNodegroupsCreationFailed

+ const ClusterStateNodegroupsCreationRequested

+ const ClusterStateProvisionInProgress

+ const ClusterStateWaitingForNodes

+ const NetworkingVpcCni

+ const NodeGroupWorker

+ const ProvisionerEKS

+ const ProvisionerKops

+ func DTOFromReader(reader io.Reader) (*T, error)

+ func DTOsFromReader(reader io.Reader) ([]*T, error)

+ func NewNodeGroupSuffix() string

type Client

+ func (c *Client) CreateNodegroups(clusterID string, request *CreateNodegroupsRequest) (*ClusterDTO, error)

+ func (c *Client) GetClusterInstallationStatus(clusterInstallationID string) (*ClusterInstallationStatus, error)

+ type ClusterInstallationStatus struct

+ InstallationFound bool

+ ReadyLocalServer *int32

+ ReadyPod *int32

+ Replicas *int32

+ RunningPod *int32

+ StartedPod *int32

+ TotalPod *int32

+ func NewClusterInstallationStatusFromReader(reader io.Reader) (*ClusterInstallationStatus, error)

type CreateClusterRequest

+ AMI string

+ AdditionalNodeGroups map[string]NodeGroupMetadata

+ ClusterRoleARN string

+ NodeGroupWithPublicSubnet []string

+ NodeGroupWithSecurityGroup []string

+ NodeRoleARN string

+ Provisioner string

+ type CreateNodegroupsRequest struct

+ NodeGroupWithPublicSubnet []string

+ NodeGroupWithSecurityGroup []string

+ Nodegroups map[string]NodeGroupMetadata

+ func NewCreateNodegroupsRequestFromReader(reader io.Reader) (*CreateNodegroupsRequest, error)

+ func (request *CreateNodegroupsRequest) SetDefaults()

+ func (request *CreateNodegroupsRequest) Validate() error

type CreateSubscriptionRequest

+ Headers Headers

type CreateWebhookRequest

+ Headers Headers

type EKSMetadata

+ AMI string

+ ChangeRequest *EKSMetadataRequestedState

+ MaxPodsPerNode int64

+ Name string

+ NodeGroups map[string]NodeGroupMetadata

+ NodeRoleARN string

+ Version string

+ Warnings []string

+ func (em *EKSMetadata) ApplyChangeRequest()

+ func (em *EKSMetadata) ApplyClusterCreateRequest(createRequest *CreateClusterRequest) bool

+ func (em *EKSMetadata) ApplyClusterSizePatch(patchRequest *PatchClusterSizeRequest) bool

+ func (em *EKSMetadata) ApplyNodegroupsCreateRequest(request *CreateNodegroupsRequest)

+ func (em *EKSMetadata) ApplyUpgradePatch(patchRequest *PatchUpgradeClusterRequest) bool

+ func (em *EKSMetadata) ClearChangeRequest()

+ func (em *EKSMetadata) ClearWarnings()

+ func (em *EKSMetadata) GetCommonMetadata() ProvisionerMetadata

+ func (em *EKSMetadata) ValidateChangeRequest() error

+ func (em *EKSMetadata) ValidateClusterSizePatch(patchRequest *PatchClusterSizeRequest) error

+ func (em *EKSMetadata) ValidateNodegroupsCreateRequest(nodegroups map[string]NodeGroupMetadata) error

+ type EKSMetadataRequestedState struct

+ AMI string

+ ClusterRoleARN string

+ MaxPodsPerNode int64

+ Networking string

+ NodeGroups map[string]NodeGroupMetadata

+ NodeRoleARN string

+ VPC string

+ Version string

+ type Headers []WebhookHeader

+ func (wh *Headers) Scan(databaseValue interface{}) error

+ func (wh Headers) GetHeaders() map[string]string

+ func (wh Headers) Validate() error

+ func (wh Headers) Value() (driver.Value, error)

type HelmUtilityVersion

+ func (u *HelmUtilityVersion) UnmarshalJSON(bytes []byte) error

type KopsMetadata

+ func (em *KopsMetadata) ValidateClusterSizePatch(patchRequest *PatchClusterSizeRequest) error

+ func (km *KopsMetadata) ApplyClusterCreateRequest(createRequest *CreateClusterRequest) bool

+ func (km *KopsMetadata) ApplyClusterSizePatch(patchRequest *PatchClusterSizeRequest) bool

+ func (km *KopsMetadata) ApplyUpgradePatch(patchRequest *PatchUpgradeClusterRequest) bool

+ func (km *KopsMetadata) GetCommonMetadata() ProvisionerMetadata

+ type LaunchTemplateData struct

+ AMI string

+ ClusterName string

+ MaxPodsPerNode int64

+ Name string

+ SecurityGroups []string

+ type NodeGroupMetadata struct

+ InstanceType string

+ MaxCount int64

+ MinCount int64

+ Name string

+ Type string

+ WithPublicSubnet bool

+ WithSecurityGroup bool

+ func (ng *NodeGroupMetadata) CopyMissingFieldsFrom(other NodeGroupMetadata)

+ type PGBouncerConfig struct

+ DefaultPoolSize int

+ MaxClientConnections int

+ MaxDatabaseConnectionsPerPool int

+ MinPoolSize int

+ ReservePoolSize int

+ ServerIdleTimeout int

+ ServerLifetime int

+ ServerResetQueryAlways int

+ func (c *PGBouncerConfig) Validate() error

type PatchClusterSizeRequest

+ NodeGroups []string

type PatchUpgradeClusterRequest

+ AMI *string

+ type ProvisionerMetadata struct

+ AMI string

+ MaxPodsPerNode int64

+ Name string

+ Networking string

+ NodeInstanceType string

+ NodeMaxCount int64

+ NodeMinCount int64

+ VPC string

+ Version string

type StateChangeEventDeliveryData

+ EventHeaders Headers

type Subscription

+ Headers Headers

type Webhook

+ Headers Headers

+ type WebhookHeader struct

+ Key string

+ Value *string

+ ValueFromEnv *string

Feb 16, 2023

Changes in this version

+ const DatabaseEngineTypePostgresProxyPerseus

+ const InstallationDatabasePerseus

+ func DateStringFromMillis(millis int64) string

+ func DateTimeStringFromMillis(millis int64) string

+ func GetMillisAtTime(t time.Time) int64

type Client

+ func (c *Client) UpdateInstallationDeletion(installationID string, request *PatchInstallationDeletionRequest) (*InstallationDTO, error)

type Installation

+ DeletionPendingExpiry int64

+ func (i *Installation) DeletionPendingExpiryCompleteTimeString() string

+ type PatchInstallationDeletionRequest struct

+ DeletionPendingExpiry *int64

+ func NewPatchInstallationDeletionRequestFromReader(reader io.Reader) (*PatchInstallationDeletionRequest, error)

+ func (p *PatchInstallationDeletionRequest) Apply(installation *Installation) bool

+ func (p *PatchInstallationDeletionRequest) Validate() error

Dec 22, 2022

Changes in this version

+ var ClusterInstallationStateWorkPriority = map[string]int

+ var InstallationStateWorkPriority = map[string]int

Dec 19, 2022

Changes in this version

+ var ClusterStateWorkPriority = map[string]int

type InstallationDatabaseStoreInterface

+ GetGroupDTOs func(filter *GroupFilter) ([]*GroupDTO, error)

Nov 28, 2022

Changes in this version

+ const DefaultMattermostDatabaseUsername

+ const DefaultPasswordLength

+ func NewRandomPassword(length int) string

+ type Certificate struct

+ ARN *string

Nov 9, 2022

Changes in this version

+ const ShowInstallationCountQueryParameter

type GetGroupsRequest

+ WithInstallationCount bool

type GroupDTO

+ InstallationCount *int64

+ func (g GroupDTO) GetInstallationCount() int64

type GroupFilter

+ WithInstallationCount bool

type Paging

+ func AllPages(includeDeleted bool) Paging

type PatchClusterSizeRequest

+ RotatorConfig *RotatorConfig

type RotatorConfig

+ func (r RotatorConfig) Validate() error

Oct 21, 2022

Changes in this version

+ func GetServerIdleTimeout() int

+ func GetServerLifetime() int

+ func SetServerIdleTimeout(val int)

+ func SetServerLifetime(val int)

Oct 7, 2022

Changes in this version

+ const ClusterStateCreationInProgress

+ const InstallationDatabaseExternal

type Cluster

+ ProvisionerMetadataEKS *EKSMetadata

type CreateClusterRequest

+ EKSConfig *EKSConfig

type CreateInstallationRequest

+ ExternalDatabaseConfig ExternalDatabaseRequest

+ type EKSConfig struct

+ ClusterRoleARN *string

+ NodeGroups map[string]EKSNodeGroup

+ type EKSMetadata struct

+ ClusterRoleARN *string

+ EKSNodeGroups EKSNodeGroups

+ KubernetesVersion *string

+ Networking string

+ VPC string

+ func NewEKSMetadata(metadataBytes []byte) (*EKSMetadata, error)

+ type EKSNodeGroup struct

+ AMIVersion *string

+ DesiredSize *int64

+ InstanceTypes []*string

+ MaxSize *int64

+ MinSize *int64

+ RoleARN *string

+ type EKSNodeGroups map[string]EKSNodeGroup

+ type ExternalDatabaseConfig struct

+ SecretName string

+ func (cfg *ExternalDatabaseConfig) ToJSON() ([]byte, error)

+ type ExternalDatabaseRequest struct

+ SecretName string

+ func (request *ExternalDatabaseRequest) ToDBConfig(database string) *ExternalDatabaseConfig

+ func (request *ExternalDatabaseRequest) Validate() error

type Installation

+ ExternalDatabaseConfig *ExternalDatabaseConfig

type InstallationDatabaseStoreInterface

+ GetInstallation func(id string, includeGroupConfig, includeGroupConfigOverrides bool) (*Installation, error)

Sep 23, 2022

Changes in this version

+ func GetDateString(millis int64) string

type MultitenantDatabase

+ func (d *MultitenantDatabase) CreationDateString() string

Sep 22, 2022

Changes in this version

+ func GetReservePoolSize() int

+ func SetReservePoolSize(val int)

Sep 14, 2022

Changes in this version

+ const ClusterInstallationStateReady

Aug 25, 2022

Changes in this version

+ const InstallationStateDeletionCancellationRequested

+ const InstallationStateDeletionPending

+ const InstallationStateDeletionPendingInProgress

+ const InstallationStateDeletionPendingRequested

type Client

+ func (c *Client) CancelInstallationDeletion(installationID string) error

type GroupStatus

+ InstallationsPendingDeletion int64

type InstallationsStatus

+ InstallationsPendingDeletion int64

type KopsMetadata

+ func (km *KopsMetadata) ApplyChangeRequest()

+ func (km *KopsMetadata) GetKopsResizeSetActionsFromChanges(changes KopsInstanceGroupMetadata, igName string) []string

Aug 1, 2022

Changes in this version

+ const ProvisionerSizePrefix

+ const SizeProvisionerXL

+ var SizeProvisionerXLResources = v1alpha1.ClusterInstallationSize

+ func GetInstallationSize(size string) (v1alpha1.ClusterInstallationSize, error)

+ func ParseProvisionerSize(size string) (v1alpha1.ClusterInstallationSize, error)

Jul 11, 2022

Changes in this version

+ const CloudproberCanonicalName

+ func GetMaxClientConnections() int

+ func SetMaxClientConnections(val int)

type PatchGroupRequest

+ ForceInstallationsRestart bool

type UtilityGroupVersions

+ Cloudprober *HelmUtilityVersion

Jun 17, 2022

Changes in this version

+ type AssignInstallationGroupRequest struct

+ GroupSelectionAnnotations []string

+ func NewAssignInstallationGroupRequestFromReader(reader io.Reader) (*AssignInstallationGroupRequest, error)

type Client

+ func (c *Client) AddInstallationDNS(installationID string, request *AddDNSRecordRequest) (*InstallationDTO, error)

+ func (c *Client) AssignGroup(installationID string, assignRequest AssignInstallationGroupRequest) error

+ func (c *Client) SetInstallationDomainPrimary(installationID, installationDNSID string) (*InstallationDTO, error)

Jun 2, 2022

Changes in this version

+ const MetricsServerCanonicalName

+ const RtcdCanonicalName

+ const VeleroCanonicalName

+ func GetAnnotationsIDs(annotations []*Annotation) []string

type Client

+ func (c *Client) AddGroupAnnotations(groupID string, annotationsRequest *AddAnnotationsRequest) (*GroupDTO, error)

+ func (c *Client) DeleteGroupAnnotation(groupID string, annotationName string) error

type CreateClusterRequest

+ MaxPodsPerNode int64

type CreateGroupRequest

+ Annotations []string

type CreateInstallationRequest

+ GroupSelectionAnnotations []string

type Group

+ func (g *Group) ToDTO(annotations []*Annotation) *GroupDTO

+ type GroupDTO struct

+ Annotations []*Annotation

+ func GroupDTOFromReader(reader io.Reader) (*GroupDTO, error)

+ func GroupDTOsFromReader(reader io.Reader) ([]*GroupDTO, error)

type GroupFilter

+ Annotations *AnnotationsFilter

type KopsMetadata

+ MaxPodsPerNode int64

type KopsMetadataRequestedState

+ MaxPodsPerNode int64

type PatchUpgradeClusterRequest

+ MaxPodsPerNode *int64

type UtilityGroupVersions

+ MetricsServer *HelmUtilityVersion

+ Rtcd *HelmUtilityVersion

+ Velero *HelmUtilityVersion

May 12, 2022

Changes in this version

+ const NetworkingAmazon

+ const NetworkingCalico

+ func DNSNamesFromRecords(dnsRecords []*InstallationDNS) []string

+ type AddDNSRecordRequest struct

+ DNS string

+ func NewAddDNSRecordRequestFromReader(reader io.Reader) (*AddDNSRecordRequest, error)

+ func (request *AddDNSRecordRequest) Validate(installationName string) error

type CreateInstallationRequest

+ DNSNames []string

+ Name string

type GetInstallationsRequest

+ Name string

type Installation

+ Name string

+ type InstallationDNS struct

+ CreateAt int64

+ DeleteAt int64

+ DomainName string

+ ID string

+ InstallationID string

+ IsPrimary bool

type InstallationDTO

+ DNS string

+ DNSRecords []*InstallationDNS

type InstallationFilter

+ Name string

Mar 30, 2022

Changes in this version

type Client

+ func (c *Client) DeleteMultitenantDatabase(databaseID string, force bool) error

type CreateInstallationRequest

+ PriorityEnv EnvVarMap

type Installation

+ PriorityEnv EnvVarMap

+ func (i Installation) GetEnvVars() EnvVarMap

type PatchInstallationRequest

+ PriorityEnv EnvVarMap

Feb 28, 2022

Changes in this version

+ func ElapsedTimeInSeconds(millis int64) float64

type StateChangeEventFilter

+ NewStates []string

+ OldStates []string

Jan 31, 2022

Changes in this version

+ const PromtailCanonicalName

type UtilityGroupVersions

+ Promtail *HelmUtilityVersion

Dec 14, 2021

Changes in this version

+ const NonApplicableState

type Client

+ func (c *Client) CreateSubscription(request *CreateSubscriptionRequest) (*Subscription, error)

+ func (c *Client) DeleteSubscription(subID string) error

+ func (c *Client) GetSubscription(subID string) (*Subscription, error)

+ func (c *Client) ListStateChangeEvents(request *ListStateChangeEventsRequest) ([]*StateChangeEventData, error)

+ func (c *Client) ListSubscriptions(request *ListSubscriptionsRequest) ([]*Subscription, error)

+ type CreateSubscriptionRequest struct

+ EventType EventType

+ FailureThreshold time.Duration

+ Name string

+ OwnerID string

+ URL string

+ func NewCreateSubscriptionRequestFromReader(reader io.Reader) (*CreateSubscriptionRequest, error)

+ func (r CreateSubscriptionRequest) ToSubscription() (Subscription, error)

+ type Event struct

+ EventType EventType

+ ExtraData EventExtraData

+ ID string

+ Timestamp int64

+ type EventDelivery struct

+ Attempts int

+ EventID string

+ ID string

+ LastAttempt int64

+ Status EventDeliveryStatus

+ SubscriptionID string

+ func EventDeliveryForEvent(eventID string, deliveries []*EventDelivery) (*EventDelivery, bool)

+ type EventDeliveryStatus string

+ const EventDeliveryDelivered

+ const EventDeliveryFailed

+ const EventDeliveryNotAttempted

+ const EventDeliveryRetrying

+ type EventExtraData struct

+ Fields map[string]string

+ type EventType string

+ const ResourceStateChangeEventType

type HelmUtilityVersion

+ func (u *HelmUtilityVersion) IsEmpty() bool

+ type ListStateChangeEventsRequest struct

+ ResourceID string

+ ResourceType ResourceType

+ func (request *ListStateChangeEventsRequest) ApplyToURL(u *url.URL)

+ type ListSubscriptionsRequest struct

+ EventType EventType

+ Owner string

+ func (request *ListSubscriptionsRequest) ApplyToURL(u *url.URL)

type ProvisionClusterRequest

+ Force bool

+ type ResourceType string

+ func (t ResourceType) String() string

+ type StateChangeEvent struct

+ EventID string

+ ID string

+ NewState string

+ OldState string

+ ResourceID string

+ ResourceType ResourceType

+ type StateChangeEventData struct

+ Event Event

+ StateChange StateChangeEvent

+ func NewStateChangeEventsDataFromReader(reader io.Reader) ([]*StateChangeEventData, error)

+ func (e *StateChangeEventData) ToEventPayload() StateChangeEventPayload

+ func (e *StateChangeEventData) ToWebhookPayload() WebhookPayload

+ type StateChangeEventDeliveryData struct

+ EventData StateChangeEventData

+ EventDelivery EventDelivery

+ type StateChangeEventFilter struct

+ ResourceID string

+ ResourceType ResourceType

+ type StateChangeEventPayload struct

+ EventID string

+ ExtraData map[string]string

+ NewState string

+ OldState string

+ ResourceID string

+ ResourceType ResourceType

+ Timestamp int64

+ func NewStateChangeEventPayloadFromReader(reader io.Reader) (*StateChangeEventPayload, error)

+ type Subscription struct

+ CreateAt int64

+ DeleteAt int64

+ EventType EventType

+ FailureThreshold time.Duration

+ ID string

+ LastDeliveryAttemptAt int64

+ LastDeliveryStatus SubscriptionDeliveryStatus

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ Name string

+ OwnerID string

+ URL string

+ func NewSubscriptionFromReader(reader io.Reader) (*Subscription, error)

+ func NewSubscriptionsFromReader(reader io.Reader) ([]*Subscription, error)

+ func (s Subscription) IsDeleted() bool

+ type SubscriptionDeliveryStatus string

+ const SubscriptionDeliveryFailed

+ const SubscriptionDeliveryNone

+ const SubscriptionDeliverySucceeded

+ type SubscriptionsFilter struct

+ EventType EventType

+ Owner string

type WebhookPayload

+ EventID string

Nov 16, 2021

Changes in this version

type RotatorConfig

+ WaitBetweenPodEvictions *int

Oct 21, 2021

Changes in this version

+ const OperationTypeDNS

+ const OperationTypeDeletingInActiveCIs

+ const OperationTypeMigration

+ const OperationTypeSwitchClusterRoles

+ func GetDefaultPoolSize() int

+ func GetMaxDatabaseConnectionsPerPool() int

+ func GetMinPoolSize() int

+ func SetDefaultPoolSize(val int) error

+ func SetMaxDatabaseConnectionsPerPool(val int) error

+ func SetMinPoolSize(val int)

+ type MigrateClusterInstallationResponse struct

+ Operation string

+ SourceClusterID string

+ TargetClusterID string

+ TotalClusterInstallations int

+ func MigrateClusterInstallationResponseFromReader(reader io.Reader) (*MigrateClusterInstallationResponse, error)

Sep 16, 2021

Changes in this version

+ func GetIDs(resources []Resource) []string

type Cluster

+ func (c *Cluster) GetID() string

+ func (c *Cluster) GetState() string

+ func (c *Cluster) IsDeleted() bool

type Installation

+ func (i *Installation) GetID() string

+ func (i *Installation) GetState() string

+ type Resource interface

+ GetID func() string

+ IsDeleted func() bool

+ func ClustersAsResources(collection []*Cluster) []Resource

+ func InstallationsAsResources(collection []*Installation) []Resource

+ type Resources []Resource

+ type SupervisedResource interface

+ GetState func() string

Sep 13, 2021

Changes in this version

+ const InstallationStateImportComplete

+ const NodeProblemDetectorCanonicalName

+ var DefaultUtilityVersions map[string]*HelmUtilityVersion = map[string]*HelmUtilityVersion

+ func GetDefaultProxyDatabaseMaxInstallationsPerLogicalDatabase() int64

+ func GetGitlabToken() string

+ func SetDefaultProxyDatabaseMaxInstallationsPerLogicalDatabase(val int64) error

+ func SetGitlabToken(val string)

type Client

+ func (c *Client) GetDatabaseSchema(multitenantDatabaseID string) (*DatabaseSchema, error)

+ func (c *Client) GetDatabaseSchemas(request *GetDatabaseSchemaRequest) ([]*DatabaseSchema, error)

+ func (c *Client) GetLogicalDatabase(logicalDatabaseID string) (*LogicalDatabase, error)

+ func (c *Client) GetLogicalDatabases(request *GetLogicalDatabasesRequest) ([]*LogicalDatabase, error)

+ func (c *Client) GetMultitenantDatabase(multitenantDatabaseID string) (*MultitenantDatabase, error)

type ClusterUtilityDatabaseStoreInterface

+ GetLogicalDatabases func(filter *LogicalDatabaseFilter) ([]*LogicalDatabase, error)

+ type DatabaseResourceGrouping struct

+ DatabaseSchema *DatabaseSchema

+ LogicalDatabase *LogicalDatabase

+ MultitenantDatabase *MultitenantDatabase

+ type DatabaseSchema struct

+ CreateAt int64

+ DeleteAt int64

+ ID string

+ InstallationID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ LogicalDatabaseID string

+ Name string

+ func DatababseSchemaFromReader(reader io.Reader) (*DatabaseSchema, error)

+ func DatababseSchemasFromReader(reader io.Reader) ([]*DatabaseSchema, error)

+ type DatabaseSchemaFilter struct

+ InstallationID string

+ LogicalDatabaseID string

+ type GetDatabaseSchemaRequest struct

+ InstallationID string

+ LogicalDatabaseID string

+ func (request *GetDatabaseSchemaRequest) ApplyToURL(u *url.URL)

+ type GetLogicalDatabasesRequest struct

+ MultitenantDatabaseID string

+ func (request *GetLogicalDatabasesRequest) ApplyToURL(u *url.URL)

+ type GetMultitenantDatabasesRequest struct

+ DatabaseType string

+ VpcID string

+ func (request *GetMultitenantDatabasesRequest) ApplyToURL(u *url.URL)

type Installation

+ func (i *Installation) IsDeleted() bool

type InstallationDatabaseStoreInterface

+ DeleteInstallationProxyDatabaseResources func(multitenantDatabase *MultitenantDatabase, databaseSchema *DatabaseSchema) error

+ GetDatabaseSchema func(databaseSchemaID string) (*DatabaseSchema, error)

+ GetDatabaseSchemas func(filter *DatabaseSchemaFilter) ([]*DatabaseSchema, error)

+ GetLogicalDatabase func(logicalDatabaseID string) (*LogicalDatabase, error)

+ GetLogicalDatabases func(filter *LogicalDatabaseFilter) ([]*LogicalDatabase, error)

+ GetOrCreateProxyDatabaseResourcesForInstallation func(installationID, multitenantDatabaseID string) (*DatabaseResourceGrouping, error)

+ GetProxyDatabaseResourcesForInstallation func(installationID string) (*DatabaseResourceGrouping, error)

+ type LogicalDatabase struct

+ CreateAt int64

+ DeleteAt int64

+ ID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ MultitenantDatabaseID string

+ Name string

+ func LogicalDatabaseFromReader(reader io.Reader) (*LogicalDatabase, error)

+ func LogicalDatabasesFromReader(reader io.Reader) ([]*LogicalDatabase, error)

+ type LogicalDatabaseFilter struct

+ MultitenantDatabaseID string

type MultitenantDatabase

+ RdsClusterID string

+ type PatchMultitenantDatabaseRequest struct

+ MaxInstallationsPerLogicalDatabase *int64

+ func NewPatchMultitenantDatabaseRequestFromReader(reader io.Reader) (*PatchMultitenantDatabaseRequest, error)

+ func (p *PatchMultitenantDatabaseRequest) Apply(database *MultitenantDatabase) bool

+ func (p *PatchMultitenantDatabaseRequest) Validate() error

type UtilityGroupVersions

+ NodeProblemDetector *HelmUtilityVersion

Aug 12, 2021

Changes in this version

+ const DatabaseEngineTypePostgresProxy

+ const DatabaseStateProvisioningRequested

+ const DatabaseStateStable

+ const InstallationDatabaseMultiTenantRDSPostgresPGBouncer

+ const InstallationStateDBMigrationRollbackInProgress

+ const InstallationStateDNSMigrationHibernating

+ const KubecostCanonicalName

+ const KubecostToken

+ const MattermostChannel

+ const MattermostWebhook

+ const StackroxCanonicalName

+ var KubecostDefaultVersion = &HelmUtilityVersion

+ var StackroxDefaultVersion = &HelmUtilityVersion

+ func ClusterNewID() string

+ func GetMillis() int64

+ func IsMultiTenantRDS(database string) bool

+ func SetDeployOperators(mysql, minio bool)

+ func SetUtilityDefaults(url string)

+ func TimeFromMillis(millis int64) time.Time

type Client

+ func (c *Client) CommitInstallationDBMigration(id string) (*InstallationDBMigrationOperation, error)

+ func (c *Client) DeleteInActiveClusterInstallationByID(clusterInstallationID string) error

+ func (c *Client) DeleteInActiveClusterInstallationsByCluster(clusterID string) error

+ func (c *Client) GetInstallationDBMigrationOperation(id string) (*InstallationDBMigrationOperation, error)

+ func (c *Client) GetInstallationDBMigrationOperations(request *GetInstallationDBMigrationOperationsRequest) ([]*InstallationDBMigrationOperation, error)

+ func (c *Client) MigrateClusterInstallation(request *MigrateClusterInstallationRequest) error

+ func (c *Client) MigrateDNS(request *MigrateClusterInstallationRequest) error

+ func (c *Client) MigrateInstallationDatabase(request *InstallationDBMigrationRequest) (*InstallationDBMigrationOperation, error)

+ func (c *Client) RollbackInstallationDBMigration(id string) (*InstallationDBMigrationOperation, error)

+ func (c *Client) SwitchClusterRoles(request *MigrateClusterInstallationRequest) error

+ func (c *Client) UpdateMultitenantDatabase(databaseID string, request *PatchDatabaseRequest) (*MultitenantDatabase, error)

type ClusterInstallation

+ IsActive bool

type ClusterInstallationFilter

+ IsActive *bool

+ type ClusterUtilityDatabaseStoreInterface interface

+ GetMultitenantDatabases func(filter *MultitenantDatabaseFilter) ([]*MultitenantDatabase, error)

type Installation

+ func (i *Installation) CreationDateString() string

+ func (i *Installation) DeletionDateString() string

type InstallationBackup

+ BackedUpDatabaseType string

type InstallationDBMigrationOperation

+ func (b InstallationDBMigrationOperation) ValidTransitionState(newState InstallationDBMigrationOperationState) bool

type InstallationDBMigrationOperationState

+ const InstallationDBMigrationStateCommitted

+ const InstallationDBMigrationStateDeleted

+ const InstallationDBMigrationStateDeletionRequested

+ const InstallationDBMigrationStateRollbackFinished

+ const InstallationDBMigrationStateRollbackRequested

type InstallationDBRestorationState

+ const InstallationDBRestorationStateDeleted

+ const InstallationDBRestorationStateDeletionRequested

+ type MigrateClusterInstallationRequest struct

+ DNSSwitch bool

+ InstallationID string

+ LockInstallation bool

+ SourceClusterID string

+ TargetClusterID string

+ func NewMigrateClusterInstallationRequestFromReader(reader io.Reader) (MigrateClusterInstallationRequest, error)

+ func (request *MigrateClusterInstallationRequest) Validate() error

type MultitenantDatabase

+ MaxInstallationsPerLogicalDatabase int64

+ ReaderEndpoint string

+ SharedLogicalDatabaseMappings SharedLogicalDatabases

+ State string

+ WriterEndpoint string

+ func MultitenantDatabaseFromReader(reader io.Reader) (*MultitenantDatabase, error)

+ func (d *MultitenantDatabase) AddInstallationToLogicalDatabaseMapping(installationID string)

+ func (d *MultitenantDatabase) GetReaderEndpoint() string

+ type PatchDatabaseRequest struct

+ MaxInstallationsPerLogicalDatabase *int64

+ func NewPatchDatabaseRequestFromReader(reader io.Reader) (*PatchDatabaseRequest, error)

+ func (p *PatchDatabaseRequest) Apply(database *MultitenantDatabase) bool

+ func (p *PatchDatabaseRequest) Validate() error

+ type SharedLogicalDatabases map[string][]string

+ func (l *SharedLogicalDatabases) GetLogicalDatabaseName(installationID string) string

+ func (l *SharedLogicalDatabases) RemoveInstallation(installationID string)

type UtilityGroupVersions

+ Kubecost *HelmUtilityVersion

+ Stackrox *HelmUtilityVersion

May 26, 2021

Changes in this version

+ const InstallationStateDBMigrationFailed

+ const InstallationStateDBMigrationInProgress

+ const InstallationStateDBRestorationFailed

+ const InstallationStateDBRestorationInProgress

+ const InstallationStateImportInProgress

+ const PgbouncerCanonicalName

+ const TypeInstallationDBMigration

+ const TypeInstallationDBRestoration

+ var AllInstallationDBMigrationOperationsStatesPendingWork = []InstallationDBMigrationOperationState

+ var AllInstallationDBRestorationStatesPendingWork = []InstallationDBRestorationState

+ var PgbouncerDefaultVersion = &HelmUtilityVersion

+ func DetermineAfterRestorationState(installation *Installation) (string, error)

+ func EnsureBackupRestoreCompatible(installation *Installation) error

+ func EnsureInstallationReadyForBackup(installation *Installation) error

+ func EnsureInstallationReadyForDBRestoration(installation *Installation, backup *InstallationBackup) error

type Client

+ func (c *Client) GetInstallationDBRestoration(id string) (*InstallationDBRestorationOperation, error)

+ func (c *Client) GetInstallationDBRestorationOperations(request *GetInstallationDBRestorationOperationsRequest) ([]*InstallationDBRestorationOperation, error)

+ func (c *Client) RestoreInstallationDatabase(installationID, backupID string) (*InstallationDBRestorationOperation, error)

type CreateClusterRequest

+ VPC string

type Database

+ MigrateOut func(store InstallationDatabaseStoreInterface, ...) error

+ MigrateTo func(store InstallationDatabaseStoreInterface, ...) error

+ RollbackMigration func(store InstallationDatabaseStoreInterface, ...) error

+ TeardownMigrated func(store InstallationDatabaseStoreInterface, ...) error

+ type GetInstallationDBMigrationOperationsRequest struct

+ ClusterInstallationID string

+ InstallationID string

+ State string

+ func (request *GetInstallationDBMigrationOperationsRequest) ApplyToURL(u *url.URL)

+ type GetInstallationDBRestorationOperationsRequest struct

+ ClusterInstallationID string

+ InstallationID string

+ State string

+ func (request *GetInstallationDBRestorationOperationsRequest) ApplyToURL(u *url.URL)

+ type InstallationDBMigrationFilter struct

+ IDs []string

+ InstallationID string

+ States []InstallationDBMigrationOperationState

+ type InstallationDBMigrationOperation struct

+ BackupID string

+ CompleteAt int64

+ DeleteAt int64

+ DestinationDatabase string

+ DestinationMultiTenant *MultiTenantDBMigrationData

+ ID string

+ InstallationDBRestorationOperationID string

+ InstallationID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ RequestAt int64

+ SourceDatabase string

+ SourceMultiTenant *MultiTenantDBMigrationData

+ State InstallationDBMigrationOperationState

+ func NewDBMigrationOperationFromReader(reader io.Reader) (*InstallationDBMigrationOperation, error)

+ func NewDBMigrationOperationsFromReader(reader io.Reader) ([]*InstallationDBMigrationOperation, error)

+ type InstallationDBMigrationOperationState string

+ const InstallationDBMigrationStateBackupInProgress

+ const InstallationDBMigrationStateDatabaseSwitch

+ const InstallationDBMigrationStateFailed

+ const InstallationDBMigrationStateFailing

+ const InstallationDBMigrationStateFinalizing

+ const InstallationDBMigrationStateRefreshSecrets

+ const InstallationDBMigrationStateRequested

+ const InstallationDBMigrationStateRestorationInProgress

+ const InstallationDBMigrationStateSucceeded

+ const InstallationDBMigrationStateTriggerRestoration

+ const InstallationDBMigrationStateUpdatingInstallationConfig

+ type InstallationDBMigrationRequest struct

+ DestinationDatabase string

+ DestinationMultiTenant *MultiTenantDBMigrationData

+ InstallationID string

+ func NewInstallationDBMigrationRequestFromReader(reader io.Reader) (*InstallationDBMigrationRequest, error)

+ type InstallationDBRestorationFilter struct

+ ClusterInstallationID string

+ IDs []string

+ InstallationID string

+ States []InstallationDBRestorationState

+ type InstallationDBRestorationOperation struct

+ BackupID string

+ ClusterInstallationID string

+ CompleteAt int64

+ DeleteAt int64

+ ID string

+ InstallationID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ RequestAt int64

+ State InstallationDBRestorationState

+ TargetInstallationState string

+ func NewInstallationDBRestorationOperationFromReader(reader io.Reader) (*InstallationDBRestorationOperation, error)

+ func NewInstallationDBRestorationOperationsFromReader(reader io.Reader) ([]*InstallationDBRestorationOperation, error)

+ type InstallationDBRestorationRequest struct

+ BackupID string

+ InstallationID string

+ func NewInstallationDBRestorationRequestFromReader(reader io.Reader) (*InstallationDBRestorationRequest, error)

+ type InstallationDBRestorationState string

+ const InstallationDBRestorationStateFailed

+ const InstallationDBRestorationStateFailing

+ const InstallationDBRestorationStateFinalizing

+ const InstallationDBRestorationStateInProgress

+ const InstallationDBRestorationStateInvalid

+ const InstallationDBRestorationStateRequested

+ const InstallationDBRestorationStateSucceeded

type InstallationDatabaseStoreInterface

+ LockMultitenantDatabases func(ids []string, lockerID string) (bool, error)

+ UnlockMultitenantDatabases func(ids []string, lockerID string, force bool) (bool, error)

type KopsMetadata

+ VPC string

type KopsMetadataRequestedState

+ VPC string

+ type MultiTenantDBMigrationData struct

+ DatabaseID string

type MultitenantDatabase

+ MigratedInstallations MultitenantDatabaseInstallations

type MultitenantDatabaseFilter

+ MigratedInstallationID string

type MysqlOperatorDatabase

+ func (d *MysqlOperatorDatabase) MigrateOut(store InstallationDatabaseStoreInterface, ...) error

+ func (d *MysqlOperatorDatabase) MigrateTo(store InstallationDatabaseStoreInterface, ...) error

+ func (d *MysqlOperatorDatabase) RollbackMigration(store InstallationDatabaseStoreInterface, ...) error

+ func (d *MysqlOperatorDatabase) TeardownMigrated(store InstallationDatabaseStoreInterface, ...) error

type UtilityGroupVersions

+ Pgbouncer *HelmUtilityVersion

Apr 9, 2021

Changes in this version

+ var AllInstallationBackupsStatesRunning = []InstallationBackupState

+ func GetSupportedCniList() []string

type Client

+ func (c *Client) CreateInstallationBackup(installationID string) (*InstallationBackup, error)

+ func (c *Client) DeleteInstallationBackup(backupID string) error

+ func (c *Client) GetInstallationBackup(backupID string) (*InstallationBackup, error)

+ func (c *Client) GetInstallationBackups(request *GetInstallationBackupsRequest) ([]*InstallationBackup, error)

+ func (c *Client) LockAPIForBackup(backupID string) error

+ func (c *Client) UnlockAPIForBackup(backupID string) error

type Cluster

+ Networking string

type CreateClusterRequest

+ Networking string

type InstallationBackup

+ func (b *InstallationBackup) ValidTransitionState(newState InstallationBackupState) bool

type InstallationBackupFilter

+ IDs []string

+ States []InstallationBackupState

type InstallationBackupState

+ const InstallationBackupStateDeleted

+ const InstallationBackupStateDeletionFailed

+ const InstallationBackupStateDeletionRequested

+ type KopsInstanceGroupMetadata struct

+ NodeInstanceType string

+ NodeMaxCount int64

+ NodeMinCount int64

+ type KopsInstanceGroupsMetadata map[string]KopsInstanceGroupMetadata

type KopsMetadata

+ CustomInstanceGroups KopsInstanceGroupsMetadata

+ MasterInstanceGroups KopsInstanceGroupsMetadata

+ Networking string

+ NodeInstanceGroups KopsInstanceGroupsMetadata

+ func (km *KopsMetadata) GetWorkerNodesResizeChanges() KopsInstanceGroupsMetadata

type KopsMetadataRequestedState

+ Networking string

+ type Paging struct

+ IncludeDeleted bool

+ Page int

+ PerPage int

+ func AllPagesNotDeleted() Paging

+ func AllPagesWithDeleted() Paging

+ func (p *Paging) AddToQuery(q url.Values)

type S3DataResidence

+ PathPrefix string

+ func (dr S3DataResidence) FullPath() string

Mar 15, 2021

Changes in this version

+ const DefaultDatabaseWeight

+ const HibernatingDatabaseWeight

+ const InstallationStateWakeUpRequested

+ const TypeInstallationBackup

+ var AllInstallationBackupStatesPendingWork = []InstallationBackupState

+ func EnsureBackupCompatible(installation *Installation) error

type Database

+ RefreshResourceMetadata func(store InstallationDatabaseStoreInterface, logger log.FieldLogger) error

+ type GetInstallationBackupsRequest struct

+ ClusterInstallationID string

+ IncludeDeleted bool

+ InstallationID string

+ Page int

+ PerPage int

+ State string

+ func (request *GetInstallationBackupsRequest) ApplyToURL(u *url.URL)

type Installation

+ func (i *Installation) GetDatabaseWeight() float64

+ type InstallationBackup struct

+ APISecurityLock bool

+ ClusterInstallationID string

+ DataResidence *S3DataResidence

+ DeleteAt int64

+ ID string

+ InstallationID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ RequestAt int64

+ StartAt int64

+ State InstallationBackupState

+ func NewInstallationBackupFromReader(reader io.Reader) (*InstallationBackup, error)

+ func NewInstallationBackupsFromReader(reader io.Reader) ([]*InstallationBackup, error)

+ type InstallationBackupFilter struct

+ ClusterInstallationID string

+ IncludeDeleted bool

+ InstallationID string

+ Page int

+ PerPage int

+ State InstallationBackupState

+ type InstallationBackupRequest struct

+ InstallationID string

+ func NewInstallationBackupRequestFromReader(reader io.Reader) (*InstallationBackupRequest, error)

+ type InstallationBackupState string

+ const InstallationBackupStateBackupFailed

+ const InstallationBackupStateBackupInProgress

+ const InstallationBackupStateBackupRequested

+ const InstallationBackupStateBackupSucceeded

type InstallationDatabaseStoreInterface

+ GetInstallationsTotalDatabaseWeight func(installationIDs []string) (float64, error)

type InstallationFilter

+ InstallationIDs []string

type KopsMetadata

+ RotatorRequest *RotatorMetadata

+ func (km *KopsMetadata) ClearRotatorRequest()

type MysqlOperatorDatabase

+ func (d *MysqlOperatorDatabase) RefreshResourceMetadata(store InstallationDatabaseStoreInterface, logger log.FieldLogger) error

type PatchUpgradeClusterRequest

+ RotatorConfig *RotatorConfig

+ type RotatorConfig struct

+ EvictGracePeriod *int

+ MaxDrainRetries *int

+ MaxScaling *int

+ UseRotator *bool

+ WaitBetweenDrains *int

+ WaitBetweenRotations *int

+ type RotatorMetadata struct

+ Config *RotatorConfig

+ Status *rotator.RotatorMetadata

+ type S3DataResidence struct

+ Bucket string

+ ObjectKey string

+ Region string

+ URL string

Mar 2, 2021

Changes in this version

type Client

+ func (c *Client) GetInstallationsStatus() (*InstallationsStatus, error)

+ type InstallationsStatus struct

+ InstallationsHibernating int64

+ InstallationsStable int64

+ InstallationsTotal int64

+ InstallationsUpdating int64

+ func InstallationsStatusFromReader(reader io.Reader) (*InstallationsStatus, error)

Feb 16, 2021

Changes in this version

type GroupStatus

+ InstallationsHibernating int64

type PatchInstallationRequest

+ OwnerID *string

Feb 1, 2021

Changes in this version

type GetInstallationsRequest

+ State string

type InstallationFilter

+ State string

type KopsMetadata

+ func (km *KopsMetadata) ValidateChangeRequest() error

Jan 19, 2021

Changes in this version

+ const DefaultCRVersion

+ const NginxInternalCanonicalName

+ const V1alphaCRVersion

+ const V1betaCRVersion

+ var NginxInternalDefaultVersion = &HelmUtilityVersion

type Database

+ GenerateDatabaseSecret func(store InstallationDatabaseStoreInterface, logger log.FieldLogger) (*corev1.Secret, error)

+ type FilestoreConfig struct

+ Bucket string

+ Secret string

+ URL string

type Installation

+ CRVersion string

type MysqlOperatorDatabase

+ func (d *MysqlOperatorDatabase) GenerateDatabaseSecret(store InstallationDatabaseStoreInterface, logger log.FieldLogger) (*corev1.Secret, error)

type UtilityGroupVersions

+ NginxInternal *HelmUtilityVersion

Jan 13, 2021

Changes in this version

+ const GitlabOAuthTokenKey

type UtilityGroupVersions

+ func (h *UtilityGroupVersions) AsMap() map[string]*HelmUtilityVersion

Dec 7, 2020

Changes in this version

+ type HelmUtilityVersion struct

+ Chart string

+ ValuesPath string

+ func (u *HelmUtilityVersion) Values() string

+ func (u *HelmUtilityVersion) Version() string

+ type UtilityGroupVersions struct

+ Fluentbit *HelmUtilityVersion

+ Nginx *HelmUtilityVersion

+ PrometheusOperator *HelmUtilityVersion

+ Teleport *HelmUtilityVersion

+ Thanos *HelmUtilityVersion

+ func (h *UtilityGroupVersions) UnmarshalJSON(bytes []byte) error

Nov 25, 2020

Changes in this version

+ func GroupsStatusFromReader(reader io.Reader) (*[]GroupsStatus, error)

+ func IsSingleTenantRDS(database string) bool

type Client

+ func (c *Client) GetGroupsStatus() (*[]GroupsStatus, error)

type CreateInstallationRequest

+ SingleTenantDatabaseConfig SingleTenantDatabaseRequest

type GroupStatus

+ InstallationsUpdating int64

+ type GroupsStatus struct

+ ID string

+ Status GroupStatus

type Installation

+ SingleTenantDatabaseConfig *SingleTenantDatabaseConfig

type InstallationDatabaseStoreInterface

+ GetSingleTenantDatabaseConfigForInstallation func(installationID string) (*SingleTenantDatabaseConfig, error)

+ type SingleTenantDatabaseConfig struct

+ PrimaryInstanceType string

+ ReplicaInstanceType string

+ ReplicasCount int

+ func NewSingleTenantDatabaseConfigurationFromReader(reader io.Reader) (*SingleTenantDatabaseConfig, error)

+ func (cfg *SingleTenantDatabaseConfig) ToJSON() ([]byte, error)

+ type SingleTenantDatabaseRequest struct

+ PrimaryInstanceType string

+ ReplicaInstanceType string

+ ReplicasCount int

+ func NewSingleTenantDatabaseRequestFromReader(reader io.Reader) (*SingleTenantDatabaseRequest, error)

+ func (request *SingleTenantDatabaseRequest) SetDefaults()

+ func (request *SingleTenantDatabaseRequest) ToDBConfig(database string) *SingleTenantDatabaseConfig

+ func (request *SingleTenantDatabaseRequest) Validate() error

Nov 6, 2020

Changes in this version

+ const InstallationFilestoreBifrost

+ func SetRequireAnnotatedInstallations(val bool)

Oct 29, 2020

Changes in this version

+ const PrometheusOperatorCanonicalName

+ const PrometheusOperatorDefaultVersion

+ const ThanosCanonicalName

+ const ThanosDefaultVersion

+ func ContainsAnnotation(annotations []*Annotation, annotation *Annotation) bool

+ type AddAnnotationsRequest struct

+ Annotations []string

+ func NewAddAnnotationsRequestFromReader(reader io.Reader) (*AddAnnotationsRequest, error)

+ type Annotation struct

+ ID string

+ Name string

+ func AnnotationsFromStringSlice(names []string) ([]*Annotation, error)

+ func SortAnnotations(annotations []*Annotation) []*Annotation

+ type AnnotationsFilter struct

+ MatchAllIDs []string

type Client

+ func (c *Client) AddClusterAnnotations(clusterID string, annotationsRequest *AddAnnotationsRequest) (*ClusterDTO, error)

+ func (c *Client) AddInstallationAnnotations(installationID string, annotationsRequest *AddAnnotationsRequest) (*InstallationDTO, error)

+ func (c *Client) DeleteClusterAnnotation(clusterID string, annotationName string) error

+ func (c *Client) DeleteInstallationAnnotation(installationID string, annotationName string) error

type Cluster

+ func (c *Cluster) ToDTO(annotations []*Annotation) *ClusterDTO

+ type ClusterDTO struct

+ Annotations []*Annotation

+ func ClusterDTOFromReader(reader io.Reader) (*ClusterDTO, error)

+ func ClusterDTOsFromReader(reader io.Reader) ([]*ClusterDTO, error)

type ClusterFilter

+ Annotations *AnnotationsFilter

type CreateClusterRequest

+ Annotations []string

type CreateInstallationRequest

+ Annotations []string

type GroupStatus

+ InstallationsUnstable int64

type Installation

+ func (i *Installation) InstallationSequenceMatchesMergedGroupSequence() bool

+ func (i *Installation) ToDTO(annotations []*Annotation) *InstallationDTO

+ type InstallationDTO struct

+ Annotations []*Annotation

+ func InstallationDTOFromReader(reader io.Reader) (*InstallationDTO, error)

+ func InstallationDTOsFromReader(reader io.Reader) ([]*InstallationDTO, error)

type PatchGroupRequest

+ ForceSequenceUpdate bool

Oct 2, 2020

Changes in this version

type Client

+ func (c *Client) GetGroupStatus(groupID string) (*GroupStatus, error)

+ type GroupStatus struct

+ InstallationsAwaitingUpdate int64

+ InstallationsTotal int64

+ InstallationsUpdated int64

+ func GroupStatusFromReader(reader io.Reader) (*GroupStatus, error)

Sep 24, 2020

Changes in this version

+ const InstallationFilestoreMultiTenantAwsS3

Sep 7, 2020

Changes in this version

+ func IsValidExecCommand(command string) bool

type Client

+ func (c *Client) ExecClusterInstallationCLI(clusterInstallationID, command string, subcommand []string) ([]byte, error)

+ type ClusterInstallationExecSubcommand []string

+ func NewClusterInstallationExecSubcommandFromReader(reader io.Reader) (ClusterInstallationExecSubcommand, error)

Aug 26, 2020

Changes in this version

+ func InstallationsCountFromReader(reader io.Reader) (int, error)

type Client

+ func (c *Client) GetInstallationsCount(includeDeleted bool) (int, error)

+ type InstallationsCount struct

+ Count int

Aug 12, 2020

Changes in this version

+ const InstallationDatabaseMultiTenantRDSMySQL

+ const InstallationDatabaseMultiTenantRDSPostgres

type Client

+ func (c *Client) GetMultitenantDatabases(request *GetDatabasesRequest) ([]*MultitenantDatabase, error)

+ func (c *Client) LockAPIForCluster(clusterID string) error

+ func (c *Client) LockAPIForClusterInstallation(clusterID string) error

+ func (c *Client) LockAPIForGroup(groupID string) error

+ func (c *Client) LockAPIForInstallation(installationID string) error

+ func (c *Client) UnlockAPIForCluster(clusterID string) error

+ func (c *Client) UnlockAPIForClusterInstallation(clusterID string) error

+ func (c *Client) UnlockAPIForGroup(groupID string) error

+ func (c *Client) UnlockAPIForInstallation(installationID string) error

type Cluster

+ APISecurityLock bool

type ClusterInstallation

+ APISecurityLock bool

type CreateClusterRequest

+ APISecurityLock bool

type CreateGroupRequest

+ APISecurityLock bool

type CreateInstallationRequest

+ APISecurityLock bool

+ type GetDatabasesRequest struct

+ DatabaseType string

+ Page int

+ PerPage int

+ VpcID string

+ func (request *GetDatabasesRequest) ApplyToURL(u *url.URL)

type Group

+ APISecurityLock bool

type Installation

+ APISecurityLock bool

type MultitenantDatabase

+ DatabaseType string

+ Installations MultitenantDatabaseInstallations

+ func MultitenantDatabasesFromReader(reader io.Reader) ([]*MultitenantDatabase, error)

type MultitenantDatabaseFilter

+ DatabaseType string

+ MaxInstallationsLimit int

+ type MultitenantDatabaseInstallations []string

+ func (i *MultitenantDatabaseInstallations) Add(installationID string)

+ func (i *MultitenantDatabaseInstallations) Contains(installationID string) bool

+ func (i *MultitenantDatabaseInstallations) Count() int

+ func (i *MultitenantDatabaseInstallations) Remove(installationID string)

Jul 30, 2020

Changes in this version

+ const DatabaseEngineTypeMySQL

+ const DatabaseEngineTypePostgres

+ const InstallationDatabaseSingleTenantRDSMySQL

+ const InstallationDatabaseSingleTenantRDSPostgres

type Client

+ func (c *Client) GetInstallationByDNS(DNS string, request *GetInstallationRequest) (*Installation, error)

type GetInstallationsRequest

+ DNS string

type InstallationFilter

+ DNS string

Jun 23, 2020

Changes in this version

+ const ClusterStateRefreshMetadata

+ const InstallationStateHibernating

+ const InstallationStateHibernationInProgress

+ const InstallationStateHibernationRequested

+ var BuildHash string

type Client

+ func (c *Client) HibernateInstallation(installationID string) (*Installation, error)

+ func (c *Client) WakeupInstallation(installationID string) (*Installation, error)

type CreateClusterRequest

+ MasterCount int64

+ MasterInstanceType string

+ NodeInstanceType string

+ NodeMaxCount int64

+ NodeMinCount int64

type KopsMetadata

+ ChangeRequest *KopsMetadataRequestedState

+ MasterCount int64

+ MasterInstanceType string

+ NodeInstanceType string

+ NodeMaxCount int64

+ NodeMinCount int64

+ Warnings []string

+ func (km *KopsMetadata) AddWarning(warning string)

+ func (km *KopsMetadata) ClearChangeRequest()

+ func (km *KopsMetadata) ClearWarnings()

+ type KopsMetadataRequestedState struct

+ AMI string

+ MasterCount int64

+ MasterInstanceType string

+ NodeInstanceType string

+ NodeMaxCount int64

+ NodeMinCount int64

+ Version string

+ type PatchClusterSizeRequest struct

+ NodeInstanceType *string

+ NodeMaxCount *int64

+ NodeMinCount *int64

+ func NewResizeClusterRequestFromReader(reader io.Reader) (*PatchClusterSizeRequest, error)

+ func (p *PatchClusterSizeRequest) Apply(metadata *KopsMetadata) bool

+ func (p *PatchClusterSizeRequest) Validate() error

Jun 10, 2020

Changes in this version

+ const TeleportCanonicalName

+ const TeleportDefaultVersion

type Cluster

+ ProviderMetadataAWS *AWSMetadata

+ ProvisionerMetadataKops *KopsMetadata

type EnvVar

+ func (e *EnvVar) HasValue() bool

type EnvVarMap

+ func (em *EnvVarMap) ClearOrPatch(new *EnvVarMap) bool

+ func (em EnvVarMap) Patch(new EnvVarMap) bool

type MultitenantDatabase

+ VpcID string

type MultitenantDatabaseFilter

+ VpcID string

type PatchInstallationRequest

+ Size *string

+ type PatchUpgradeClusterRequest struct

+ KopsAMI *string

+ Version *string

+ func NewUpgradeClusterRequestFromReader(reader io.Reader) (*PatchUpgradeClusterRequest, error)

+ func (p *PatchUpgradeClusterRequest) Apply(metadata *KopsMetadata) bool

+ func (p *PatchUpgradeClusterRequest) Validate() error

type UtilityMetadata

+ func NewUtilityMetadata(metadataBytes []byte) (*UtilityMetadata, error)

May 15, 2020

Changes in this version

+ const ClusterStateResizeFailed

+ const ClusterStateResizeRequested

+ const InstallationDatabaseMultiTenantRDS

+ const InstallationDatabaseSingleTenantRDS

+ const InstallationStateCreationFinalTasks

+ const NoInstallationsLimit

type Client

+ func (c *Client) ResizeCluster(clusterID, size string) error

+ func (c *Client) UpdateInstallation(installationID string, request *PatchInstallationRequest) (*Installation, error)

type Group

+ func (g *Group) IsDeleted() bool

type InstallationDatabaseStoreInterface

+ AddMultitenantDatabaseInstallationID func(rdsClusterID, installationID string) (MultitenantDatabaseInstallationIDs, error)

+ CreateMultitenantDatabase func(multitenantDatabase *MultitenantDatabase) error

+ GetMultitenantDatabase func(multitenantdatabaseID string) (*MultitenantDatabase, error)

+ GetMultitenantDatabaseForInstallationID func(installationID string) (*MultitenantDatabase, error)

+ GetMultitenantDatabases func(filter *MultitenantDatabaseFilter) ([]*MultitenantDatabase, error)

+ LockMultitenantDatabase func(multitenantdatabaseID, lockerID string) (bool, error)

+ RemoveMultitenantDatabaseInstallationID func(rdsClusterID, installationID string) (MultitenantDatabaseInstallationIDs, error)

+ UnlockMultitenantDatabase func(multitenantdatabaseID, lockerID string, force bool) (bool, error)

+ UpdateMultitenantDatabase func(multitenantDatabase *MultitenantDatabase) error

+ type MultitenantDatabase struct

+ CreateAt int64

+ DeleteAt int64

+ ID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ RawInstallationIDs []byte

+ func (c *MultitenantDatabase) GetInstallationIDs() (MultitenantDatabaseInstallationIDs, error)

+ func (c *MultitenantDatabase) SetInstallationIDs(installationIDs MultitenantDatabaseInstallationIDs) error

+ type MultitenantDatabaseFilter struct

+ InstallationID string

+ LockerID string

+ NumOfInstallationsLimit int

+ Page int

+ PerPage int

+ type MultitenantDatabaseInstallationIDs []string

+ func (d *MultitenantDatabaseInstallationIDs) Add(installationID string)

+ func (d *MultitenantDatabaseInstallationIDs) Contains(installationID string) bool

+ func (d *MultitenantDatabaseInstallationIDs) Remove(installationID string)

+ type PatchInstallationRequest struct

+ Image *string

+ License *string

+ MattermostEnv EnvVarMap

+ Version *string

+ func NewPatchInstallationRequestFromReader(reader io.Reader) (*PatchInstallationRequest, error)

+ func (p *PatchInstallationRequest) Apply(installation *Installation) bool

+ func (p *PatchInstallationRequest) Validate() error

Apr 3, 2020

Changes in this version

+ const CertManagerCanonicalName

+ const CertManagerDefaultVersion

+ const DatabaseMigrationStatusReplicationComplete

+ const DatabaseMigrationStatusReplicationIP

+ const DatabaseMigrationStatusSetupComplete

+ const DatabaseMigrationStatusSetupIP

+ const DatabaseMigrationStatusTeardownComplete

+ const DatabaseMigrationStatusTeardownIP

+ const PublicNginxCanonicalName

+ const PublicNginxDefaultVersion

+ type CIMigrationDatabase interface

+ Replicate func(logger log.FieldLogger) (string, error)

+ Setup func(logger log.FieldLogger) (string, error)

+ Teardown func(logger log.FieldLogger) (string, error)

type CreateGroupRequest

+ Image string

+ MaxRolling int64

+ func (request *CreateGroupRequest) SetDefaults()

type CreateInstallationRequest

+ GroupID string

+ Image string

type GetInstallationsRequest

+ GroupID string

+ IncludeGroupConfig bool

+ IncludeGroupConfigOverrides bool

type Group

+ Image string

type Installation

+ Image string

+ func (i *Installation) SyncGroupAndInstallationSequence()

+ type LeaveGroupRequest struct

+ RetainConfig bool

+ func (request *LeaveGroupRequest) ApplyToURL(u *url.URL)

type PatchGroupRequest

+ Image *string

+ MaxRolling *int64

type UpdateInstallationRequest

+ Image string

Mar 23, 2020

Changes in this version

type CreateGroupRequest

+ MattermostEnv EnvVarMap

+ func (request *CreateGroupRequest) Validate() error

type Database

+ Snapshot func(logger log.FieldLogger) error

type EnvVarMap

+ func EnvVarFromJSON(raw []byte) (*EnvVarMap, error)

+ func (em *EnvVarMap) ToJSON() ([]byte, error)

+ type GetInstallationRequest struct

+ IncludeGroupConfig bool

+ IncludeGroupConfigOverrides bool

+ func (request *GetInstallationRequest) ApplyToURL(u *url.URL)

type Group

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ MattermostEnv EnvVarMap

+ MaxRolling int64

+ Sequence int64

type Installation

+ GroupOverrides map[string]string

+ GroupSequence *int64

+ func (i *Installation) ConfigMergedWithGroup() bool

+ func (i *Installation) IsInGroup() bool

+ func (i *Installation) MergeWithGroup(group *Group, includeOverrides bool)

type MysqlOperatorDatabase

+ func (d *MysqlOperatorDatabase) Snapshot(logger log.FieldLogger) error

type PatchGroupRequest

+ MattermostEnv EnvVarMap

+ func (p *PatchGroupRequest) Validate() error

Feb 24, 2020

Changes in this version

+ const InstallationStateUpdateFailed

+ const InstallationStateUpdateInProgress

+ const InstallationStateUpdateRequested

type CreateInstallationRequest

+ MattermostEnv EnvVarMap

+ type EnvVar struct

+ Value string

+ ValueFrom *corev1.EnvVarSource

+ func (e *EnvVar) Validate() error

+ type EnvVarMap map[string]EnvVar

+ func (em *EnvVarMap) ToEnvList() []corev1.EnvVar

+ func (em *EnvVarMap) Validate() error

type Installation

+ MattermostEnv EnvVarMap

+ type UpdateInstallationRequest struct

+ License string

+ MattermostEnv EnvVarMap

+ Version string

+ func NewUpdateInstallationRequestFromReader(reader io.Reader) (*UpdateInstallationRequest, error)

+ func (request *UpdateInstallationRequest) SetDefaults()

+ func (request *UpdateInstallationRequest) Validate() error

Feb 8, 2020

Changes in this version

+ const FluentbitCanonicalName

+ const FluentbitDefaultVersion

+ const NginxCanonicalName

+ const NginxDefaultVersion

+ const PrometheusCanonicalName

+ const PrometheusDefaultVersion

Feb 6, 2020

Changes in this version

+ const FLUENTBIT

+ const NGINX

+ const PROMETHEUS

type Client

+ func (c *Client) GetClusterUtilities(clusterID string) (*UtilityMetadata, error)

type Cluster

+ UtilityMetadata []byte

+ func (c *Cluster) ActualUtilityVersion(utility string) (string, error)

+ func (c *Cluster) DesiredUtilityVersion(utility string) (string, error)

+ func (c *Cluster) SetUtilityActualVersion(utility string, version string) error

+ func (c *Cluster) SetUtilityDesiredVersions(versions map[string]string) error

type CreateClusterRequest

+ DesiredUtilityVersions map[string]string

+ type ProvisionClusterRequest struct

+ DesiredUtilityVersions map[string]string

+ func NewProvisionClusterRequestFromReader(reader io.Reader) (*ProvisionClusterRequest, error)

+ type UtilityMetadata struct

+ ActualVersions utilityVersions

+ DesiredVersions utilityVersions

+ func UtilityMetadataFromReader(reader io.Reader) (*UtilityMetadata, error)

Feb 4, 2020

Changes in this version

type InstallationFilter

+ GroupID string

Jan 8, 2020

Changes in this version

type CreateClusterRequest

+ func (request *CreateClusterRequest) SetDefaults()

+ func (request *CreateClusterRequest) Validate() error

+ type InstallationDatabaseStoreInterface interface

+ GetClusterInstallations func(filter *ClusterInstallationFilter) ([]*ClusterInstallation, error)

type WebhookPayload

+ ExtraData map[string]string

Nov 28, 2019

Changes in this version

+ const SizeAlef10000

+ const SizeAlefDev

+ var AllClusterInstallationStates = []string

+ var AllClusterInstallationStatesPendingWork = []string

+ func ValidClusterVersion(name string) bool

type Cluster

+ Version string

type CreateClusterRequest

+ KopsAMI string

+ Version string

type KopsMetadata

+ AMI string

+ Version string

Nov 1, 2019

Changes in this version

+ var AllClusterRequestStates = []string

+ var AllClusterStates = []string

+ var AllClusterStatesPendingWork = []string

+ var AllInstallationRequestStates = []string

+ var AllInstallationStates = []string

+ var AllInstallationStatesPendingWork = []string

type Client

+ func (c *Client) UpdateCluster(clusterID string, request *UpdateClusterRequest) (*Cluster, error)

type Cluster

+ func (c *Cluster) ValidTransitionState(newState string) bool

+ type ClusterStateReport []StateReportEntry

+ func GetClusterRequestStateReport() ClusterStateReport

type CreateClusterRequest

+ AllowInstallations bool

+ type Database interface

+ GenerateDatabaseSpecAndSecret func(logger log.FieldLogger) (*mmv1alpha1.Database, *corev1.Secret, error)

+ Provision func(logger log.FieldLogger) error

+ Teardown func(keepData bool, logger log.FieldLogger) error

type Installation

+ func (i *Installation) GetDatabase() Database

+ func (i *Installation) InternalDatabase() bool

+ func (i *Installation) ValidTransitionState(newState string) bool

+ type InstallationStateReport []StateReportEntry

+ func GetInstallationRequestStateReport() InstallationStateReport

+ type MysqlOperatorDatabase struct

+ func NewMysqlOperatorDatabase() *MysqlOperatorDatabase

+ func (d *MysqlOperatorDatabase) GenerateDatabaseSpecAndSecret(logger log.FieldLogger) (*mmv1alpha1.Database, *corev1.Secret, error)

+ func (d *MysqlOperatorDatabase) Provision(logger log.FieldLogger) error

+ func (d *MysqlOperatorDatabase) Teardown(keepData bool, logger log.FieldLogger) error

+ type StateList []string

+ func (sl *StateList) Count() int

+ type StateReportEntry struct

+ InvalidStates StateList

+ RequestedState string

+ ValidStates StateList

+ type UpdateClusterRequest struct

+ AllowInstallations bool

+ func NewUpdateClusterRequestFromReader(reader io.Reader) (*UpdateClusterRequest, error)

Oct 23, 2019

Changes in this version

+ const InstallationDatabaseAwsRDS

+ const InstallationDatabaseMysqlOperator

+ const InstallationFilestoreAwsS3

+ const InstallationFilestoreMinioOperator

+ const InstallationStateCreationInProgress

+ const InstallationStateCreationPreProvisioning

+ const InstallationStateDeletionFinalCleanup

+ const SizeAlef5000

+ func IsSupportedClusterSize(size string) bool

+ func IsSupportedDatabase(database string) bool

+ func IsSupportedFilestore(filestore string) bool

type Client

+ func NewClientWithHeaders(address string, headers map[string]string) *Client

type CreateInstallationRequest

+ Database string

+ Filestore string

+ func (request *CreateInstallationRequest) SetDefaults()

+ func (request *CreateInstallationRequest) Validate() error

+ type Filestore interface

+ GenerateFilestoreSpecAndSecret func(logger log.FieldLogger) (*mmv1alpha1.Minio, *corev1.Secret, error)

+ Provision func(logger log.FieldLogger) error

+ Teardown func(keepData bool, logger log.FieldLogger) error

type Installation

+ Database string

+ Filestore string

+ func (i *Installation) GetFilestore() Filestore

+ func (i *Installation) InternalFilestore() bool

+ type MinioOperatorFilestore struct

+ func NewMinioOperatorFilestore() *MinioOperatorFilestore

+ func (f *MinioOperatorFilestore) GenerateFilestoreSpecAndSecret(logger log.FieldLogger) (*mmv1alpha1.Minio, *corev1.Secret, error)

+ func (f *MinioOperatorFilestore) Provision(logger log.FieldLogger) error

+ func (f *MinioOperatorFilestore) Teardown(keepData bool, logger log.FieldLogger) error

Aug 15, 2019

Changes in this version

type ClusterInstallation

+ func (c *ClusterInstallation) IsDeleted() bool

Aug 14, 2019

Changes in this version

+ const TypeCluster

+ const TypeClusterInstallation

+ const TypeInstallation

type Client

+ func (c *Client) CreateWebhook(request *CreateWebhookRequest) (*Webhook, error)

+ func (c *Client) DeleteWebhook(webhookID string) error

+ func (c *Client) GetWebhook(webhookID string) (*Webhook, error)

+ func (c *Client) GetWebhooks(request *GetWebhooksRequest) ([]*Webhook, error)

+ func (c *Client) RunMattermostCLICommandOnClusterInstallation(clusterInstallationID string, subcommand []string) ([]byte, error)

+ type ClusterInstallationMattermostCLISubcommand []string

+ func NewClusterInstallationMattermostCLISubcommandFromReader(reader io.Reader) (ClusterInstallationMattermostCLISubcommand, error)

+ type CreateWebhookRequest struct

+ OwnerID string

+ URL string

+ func NewCreateWebhookRequestFromReader(reader io.Reader) (*CreateWebhookRequest, error)

+ type GetWebhooksRequest struct

+ IncludeDeleted bool

+ OwnerID string

+ Page int

+ PerPage int

+ func (request *GetWebhooksRequest) ApplyToURL(u *url.URL)

+ type Webhook struct

+ CreateAt int64

+ DeleteAt int64

+ ID string

+ OwnerID string

+ URL string

+ func WebhookFromReader(reader io.Reader) (*Webhook, error)

+ func WebhooksFromReader(reader io.Reader) ([]*Webhook, error)

+ func (w *Webhook) IsDeleted() bool

+ type WebhookFilter struct

+ IncludeDeleted bool

+ OwnerID string

+ Page int

+ PerPage int

+ type WebhookPayload struct

+ ID string

+ NewState string

+ OldState string

+ Timestamp int64

+ Type string

+ func WebhookPayloadFromReader(reader io.Reader) (*WebhookPayload, error)

+ func (p *WebhookPayload) ToJSON() (string, error)

Jul 26, 2019

Changes in this version

+ const AllPerPage

+ const ClusterInstallationStateCreationFailed

+ const ClusterInstallationStateCreationRequested

+ const ClusterInstallationStateDeleted

+ const ClusterInstallationStateDeletionFailed

+ const ClusterInstallationStateDeletionRequested

+ const ClusterInstallationStateReconciling

+ const ClusterInstallationStateStable

+ const ClusterStateCreationFailed

+ const ClusterStateCreationRequested

+ const ClusterStateDeleted

+ const ClusterStateDeletionFailed

+ const ClusterStateDeletionRequested

+ const ClusterStateProvisioningFailed

+ const ClusterStateProvisioningRequested

+ const ClusterStateStable

+ const ClusterStateUpgradeFailed

+ const ClusterStateUpgradeRequested

+ const InstallationAffinityIsolated

+ const InstallationAffinityMultiTenant

+ const InstallationDefaultSize

+ const InstallationStateCreationDNS

+ const InstallationStateCreationFailed

+ const InstallationStateCreationNoCompatibleClusters

+ const InstallationStateCreationRequested

+ const InstallationStateDeleted

+ const InstallationStateDeletionFailed

+ const InstallationStateDeletionInProgress

+ const InstallationStateDeletionRequested

+ const InstallationStateStable

+ const InstallationStateUpgradeFailed

+ const InstallationStateUpgradeInProgress

+ const InstallationStateUpgradeRequested

+ const ProviderAWS

+ const SizeAlef1000

+ const SizeAlef500

+ var InstallationSizes = []string

+ func CheckProvider(provider string) (string, error)

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

+ func IsSupportedAffinity(affinity string) bool

+ func IsSupportedSize(size string) bool

+ func NewID() string

+ type AWSMetadata struct

+ Zones []string

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

+ type Client struct

+ func NewClient(address string) *Client

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type Cluster struct

+ AllowInstallations bool

+ CreateAt int64

+ DeleteAt int64

+ ID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ Provider string

+ ProviderMetadata []byte

+ Provisioner string

+ ProvisionerMetadata []byte

+ Size string

+ State string

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

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

+ func (c *Cluster) Clone() *Cluster

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

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

+ type ClusterFilter struct

+ IncludeDeleted bool

+ Page int

+ PerPage int

+ type ClusterInstallation struct

+ ClusterID string

+ CreateAt int64

+ DeleteAt int64

+ ID string

+ InstallationID string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ Namespace string

+ State string

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

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

+ func (c *ClusterInstallation) Clone() *ClusterInstallation

+ type ClusterInstallationConfigRequest map[string]interface

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

+ type ClusterInstallationFilter struct

+ ClusterID string

+ IDs []string

+ IncludeDeleted bool

+ InstallationID string

+ Page int

+ PerPage int

+ type CreateClusterRequest struct

+ Provider string

+ Size string

+ Zones []string

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

+ type CreateGroupRequest struct

+ Description string

+ Name string

+ Version string

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

+ type CreateInstallationRequest struct

+ Affinity string

+ DNS string

+ License string

+ OwnerID string

+ Size string

+ Version string

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

+ type GetClusterInstallationsRequest struct

+ ClusterID string

+ IncludeDeleted bool

+ InstallationID string

+ Page int

+ PerPage int

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

+ type GetClustersRequest struct

+ IncludeDeleted bool

+ Page int

+ PerPage int

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

+ type GetGroupsRequest struct

+ IncludeDeleted bool

+ Page int

+ PerPage int

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

+ type GetInstallationsRequest struct

+ IncludeDeleted bool

+ OwnerID string

+ Page int

+ PerPage int

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

+ type Group struct

+ CreateAt int64

+ DeleteAt int64

+ Description string

+ ID string

+ Name string

+ Version string

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

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

+ func (c *Group) Clone() *Group

+ type GroupFilter struct

+ IncludeDeleted bool

+ Page int

+ PerPage int

+ type Installation struct

+ Affinity string

+ CreateAt int64

+ DNS string

+ DeleteAt int64

+ GroupID *string

+ ID string

+ License string

+ LockAcquiredAt int64

+ LockAcquiredBy *string

+ OwnerID string

+ Size string

+ State string

+ Version string

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

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

+ func (c *Installation) Clone() *Installation

+ type InstallationFilter struct

+ IncludeDeleted bool

+ OwnerID string

+ Page int

+ PerPage int

+ type KopsMetadata struct

+ Name string

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

+ type PatchGroupRequest struct

+ Description *string

+ ID string

+ Name *string

+ Version *string

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

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

+ type UpgradeInstallationRequest struct

+ License string

+ Version string

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