azurearcv2

Documentation

Index

• type AKSIdentityTypeProp
• type AzureArcV2Provider
  • func NewAzureArcProvider(ctx context.Context, cid, app, cluster, level, namespace string) (*AzureArcV2Provider, error)
  • func (p *AzureArcV2Provider) Apply(ctx context.Context, name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *AzureArcV2Provider) ApplyConfig(ctx context.Context, config interface{}) error
  • func (p *AzureArcV2Provider) ApplyStatusCR(ctx context.Context, name string, content []byte) error
  • func (p *AzureArcV2Provider) CleanClientProvider() error
  • func (p *AzureArcV2Provider) Commit(ctx context.Context, ref interface{}) error
  • func (p *AzureArcV2Provider) Create(name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *AzureArcV2Provider) Delete(name string, ref interface{}, content []byte) (interface{}, error)
  • func (p *AzureArcV2Provider) DeleteConfig(ctx context.Context, config interface{}) error
  • func (p *AzureArcV2Provider) DeleteStatusCR(ctx context.Context, name string, content []byte) error
  • func (p *AzureArcV2Provider) Get(ctx context.Context, name string, gvkRes []byte) ([]byte, error)
  • func (p *AzureArcV2Provider) IsReachable() error
  • func (p *AzureArcV2Provider) StartClusterWatcher(ctx context.Context) error
  • func (p *AzureArcV2Provider) TagResource(res []byte, label map[string]string) ([]byte, error)
• type ExtensionProp
• type FluxExtension
• type KustomizationProperties
• type KustomizationsUnit
• type PropertiesFlux
• type RepoProperties
• type RepoRef
• type RequestbodyFlux
• type Token

Types

type AKSIdentityTypeProp

type AKSIdentityTypeProp struct {
	Type string `json:"type"`
}

type AzureArcV2Provider

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

func NewAzureArcProvider

func NewAzureArcProvider(ctx context.Context, cid, app, cluster, level, namespace string) (*AzureArcV2Provider, error)

func (*AzureArcV2Provider) Apply

func (p *AzureArcV2Provider) Apply(ctx context.Context, name string, ref interface{}, content []byte) (interface{}, error)

Apply resource to the cluster

func (*AzureArcV2Provider) ApplyConfig

func (p *AzureArcV2Provider) ApplyConfig(ctx context.Context, config interface{}) error

Function to create gitconfiguration of fluxv1 type in azure params : ctx context.Context, config interface{} return : error

func (*AzureArcV2Provider) ApplyStatusCR

func (p *AzureArcV2Provider) ApplyStatusCR(ctx context.Context, name string, content []byte) error

ApplyStatusCR applies status CR

func (*AzureArcV2Provider) CleanClientProvider

func (p *AzureArcV2Provider) CleanClientProvider() error

func (*AzureArcV2Provider) Commit

func (p *AzureArcV2Provider) Commit(ctx context.Context, ref interface{}) error

Commit resources to the cluster

func (*AzureArcV2Provider) Create

func (p *AzureArcV2Provider) Create(name string, ref interface{}, content []byte) (interface{}, error)

Creates a new resource if the not already existing

func (*AzureArcV2Provider) Delete

func (p *AzureArcV2Provider) Delete(name string, ref interface{}, content []byte) (interface{}, error)

Delete resource from the cluster

func (*AzureArcV2Provider) DeleteConfig

func (p *AzureArcV2Provider) DeleteConfig(ctx context.Context, config interface{}) error

Function to delete the git configuration params : ctx context.Context, config interface{} return : error

func (*AzureArcV2Provider) DeleteStatusCR

func (p *AzureArcV2Provider) DeleteStatusCR(ctx context.Context, name string, content []byte) error

DeleteStatusCR deletes status CR

func (*AzureArcV2Provider) Get

func (p *AzureArcV2Provider) Get(ctx context.Context, name string, gvkRes []byte) ([]byte, error)

Get resource from the cluster

func (*AzureArcV2Provider) IsReachable

func (p *AzureArcV2Provider) IsReachable() error

IsReachable cluster reachablity test

func (*AzureArcV2Provider) StartClusterWatcher

func (p *AzureArcV2Provider) StartClusterWatcher(ctx context.Context) error

StartClusterWatcher watches for CR Same as K8s

func (*AzureArcV2Provider) TagResource

func (p *AzureArcV2Provider) TagResource(res []byte, label map[string]string) ([]byte, error)

type ExtensionProp

type ExtensionProp struct {
	ExtensionType           string `json:"extensionType"`
	AutoUpgradeMinorVersion bool   `json:"autoUpgradeMinorVersion"`
}

type FluxExtension

type FluxExtension struct {
	AKSIdentityType AKSIdentityTypeProp `json:"aksIdentityType"`
	Properties      ExtensionProp       `json:"properties"`
}

type KustomizationProperties

type KustomizationProperties struct {
	Path                   string `json:"path"`
	TimeoutInSeconds       int    `json:"timeoutInSeconds"`
	SyncIntervalInSeconds  int    `json:"syncIntervalInSeconds"`
	RetryIntervalInSeconds int    `json:"retryIntervalInSeconds"`
	Prune                  bool   `json:"prune"`
	Force                  bool   `json:"force"`
}

type KustomizationsUnit

type KustomizationsUnit struct {
	FirstKustomization KustomizationProperties `json:"kustomization-1"`
}

type PropertiesFlux

type PropertiesFlux struct {
	Scope          string             `json:"scope"`
	Namespace      string             `json:"namespace"`
	SourceKind     string             `json:"sourceKind"`
	Suspend        bool               `json:"suspend"`
	GitRepository  RepoProperties     `json:"gitRepository"`
	Kustomizations KustomizationsUnit `json:"kustomizations"`
}

type RepoProperties

type RepoProperties struct {
	Url           string  `json:"url"`
	RepositoryRef RepoRef `json:"repositoryRef"`
}

type RepoRef

type RepoRef struct {
	Branch string `json:"branch"`
}

type RequestbodyFlux

type RequestbodyFlux struct {
	Properties PropertiesFlux `json:"properties"`
}

type Token

type Token struct {
	TokenType    string `json:"token_type"`
	ExpiresIn    string `json:"expires_in"`
	ExtExpiresIn string `json:"ext_expires_in"`
	ExpiresOn    string `json:"expires_on"`
	NotBefore    string `json:"not_before"`
	Resource     string `json:"resource"`
	AccessToken  string `json:"access_token"`
}