ArgoUtil

Documentation

Index

• type ApplicationService
• type ApplicationServiceImpl
  • func NewApplicationServiceImpl(session *ArgoSession) *ApplicationServiceImpl
  • func (impl *ApplicationServiceImpl) CreateApplication(appRequest *v1alpha1.Application, ctx context.Context) (appResponse *v1alpha1.Application, err error)
  • func (impl *ApplicationServiceImpl) Delete(appName string, ctx context.Context) error
  • func (impl *ApplicationServiceImpl) GetAll(ctx context.Context) (*v1alpha1.ApplicationList, error)
• type ArgoConfig
  • func GetArgoConfig() (*ArgoConfig, error)
• type ArgoSession
  • func GetTestClient() (session *ArgoSession, err error)
  • func NewArgoSession(config *ArgoConfig, logger *zap.SugaredLogger) (session *ArgoSession, err error)
  • func (session *ArgoSession) DoRequest(clientRequest *ClientRequest) (resBody []byte, resCode *StatusCode, err error)
• type ClientRequest
• type ClusterService
• type ClusterServiceImpl
  • func NewClusterServiceImpl(session *ArgoSession) *ClusterServiceImpl
  • func (impl *ClusterServiceImpl) ClusterList() (*v1alpha1.ClusterList, error)
  • func (impl *ClusterServiceImpl) CreateCluster(cluster v1alpha1.Cluster) (*v1alpha1.Cluster, error)
  • func (impl *ClusterServiceImpl) DeleteCluster(server string) (string, error)
  • func (impl *ClusterServiceImpl) GetClusterByServer(server string) (*v1alpha1.Cluster, error)
  • func (impl *ClusterServiceImpl) UpdateCluster(cluster v1alpha1.Cluster) (*v1alpha1.Cluster, error)
• type CubeConfigCreate
• type Items
• type PodContainerLogReq
• type RepositoryService
• type RepositoryServiceImpl
  • func NewRepositoryService(session *ArgoSession) *RepositoryServiceImpl
  • func (impl RepositoryServiceImpl) Create(repositoryRequest *v1alpha1.Repository) (repository *v1alpha1.Repository, err error)
• type Resource
• type ResourceService
• type ResourceServiceImpl
  • func NewResourceServiceImpl(session *ArgoSession) *ResourceServiceImpl
  • func (impl *ResourceServiceImpl) FetchPodContainerLogs(appName string, podName string, req PodContainerLogReq) (*Items, error)
  • func (impl *ResourceServiceImpl) FetchResourceTree(appName string) (*Items, error)
• type StatusCode
  • func (code StatusCode) IsSuccess() bool

Types

type ApplicationService

type ApplicationService interface {
	GetAll(ctx context.Context) (*v1alpha1.ApplicationList, error)
	CreateApplication(appRequest *v1alpha1.Application, ctx context.Context) (appResponse *v1alpha1.Application, err error)
	Delete(appName string, ctx context.Context) error
}

type ApplicationServiceImpl

type ApplicationServiceImpl struct {
	*ArgoSession
	// contains filtered or unexported fields
}

func NewApplicationServiceImpl

func NewApplicationServiceImpl(session *ArgoSession) *ApplicationServiceImpl

func (*ApplicationServiceImpl) CreateApplication

func (impl *ApplicationServiceImpl) CreateApplication(appRequest *v1alpha1.Application, ctx context.Context) (appResponse *v1alpha1.Application, err error)

func (*ApplicationServiceImpl) Delete

func (impl *ApplicationServiceImpl) Delete(appName string, ctx context.Context) error

func (*ApplicationServiceImpl) GetAll

func (impl *ApplicationServiceImpl) GetAll(ctx context.Context) (*v1alpha1.ApplicationList, error)

type ArgoConfig

type ArgoConfig struct {
	Url                string `env:"ACD_URL" envDefault:""`
	UserName           string `env:"ACD_USER" `
	Password           string `env:"ACD_PASSWORD" `
	Timeout            int    `env:"ACD_TIMEOUT" envDefault:"0"`        // in seconds
	InsecureSkipVerify bool   `env:"ACD_SKIP_VERIFY" envDefault:"true"` //ignore ssl verification
}

func GetArgoConfig

func GetArgoConfig() (*ArgoConfig, error)

type ArgoSession

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

func GetTestClient

func GetTestClient() (session *ArgoSession, err error)

func NewArgoSession

func NewArgoSession(config *ArgoConfig, logger *zap.SugaredLogger) (session *ArgoSession, err error)

func (*ArgoSession) DoRequest

func (session *ArgoSession) DoRequest(clientRequest *ClientRequest) (resBody []byte, resCode *StatusCode, err error)

type ClientRequest

type ClientRequest struct {
	Method       string
	Path         string
	RequestBody  interface{}
	ResponseBody interface{}
}

type ClusterService

type ClusterService interface {
	GetClusterByServer(server string) (*v1alpha1.Cluster, error)
	ClusterList() (*v1alpha1.ClusterList, error)
	CreateCluster(cluster v1alpha1.Cluster) (*v1alpha1.Cluster, error)
	UpdateCluster(cluster v1alpha1.Cluster) (*v1alpha1.Cluster, error)
	DeleteCluster(server string) (string, error)
}

type ClusterServiceImpl

type ClusterServiceImpl struct {
	*ArgoSession
	// contains filtered or unexported fields
}

func NewClusterServiceImpl

func NewClusterServiceImpl(session *ArgoSession) *ClusterServiceImpl

func (*ClusterServiceImpl) ClusterList

func (impl *ClusterServiceImpl) ClusterList() (*v1alpha1.ClusterList, error)

func (*ClusterServiceImpl) CreateCluster

func (impl *ClusterServiceImpl) CreateCluster(cluster v1alpha1.Cluster) (*v1alpha1.Cluster, error)

func (*ClusterServiceImpl) DeleteCluster

func (impl *ClusterServiceImpl) DeleteCluster(server string) (string, error)

func (*ClusterServiceImpl) GetClusterByServer

func (impl *ClusterServiceImpl) GetClusterByServer(server string) (*v1alpha1.Cluster, error)

func (*ClusterServiceImpl) UpdateCluster

func (impl *ClusterServiceImpl) UpdateCluster(cluster v1alpha1.Cluster) (*v1alpha1.Cluster, error)

type CubeConfigCreate

type CubeConfigCreate struct {
	Context    string `json:"context"`
	InCluster  bool   `json:"inCluster"`
	Kubeconfig string `json:"kubeconfig"`
	Upsert     bool   `json:"upsert"`
}

type Items

type Items struct {
	Items []Resource `json:"items"`
}

type PodContainerLogReq

type PodContainerLogReq struct {
	Namespace    string `json:"namespace,omitempty"`
	Container    string `json:"container,omitempty"`
	SinceSeconds string `json:"sinceSeconds,omitempty"`
	TailLines    string `json:"tailLines,omitempty"`
	Follow       bool   `json:"follow,omitempty"`
}

type RepositoryService

type RepositoryService interface {
	Create(repositoryRequest *v1alpha1.Repository) (repository *v1alpha1.Repository, err error)
}

type RepositoryServiceImpl

type RepositoryServiceImpl struct {
	*ArgoSession
	// contains filtered or unexported fields
}

func NewRepositoryService

func NewRepositoryService(session *ArgoSession) *RepositoryServiceImpl

func (RepositoryServiceImpl) Create

func (impl RepositoryServiceImpl) Create(repositoryRequest *v1alpha1.Repository) (repository *v1alpha1.Repository, err error)

type Resource

type Resource struct {
	v1alpha1.ResourceNode `json:",inline" protobuf:"bytes,1,opt,name=resourceNode"`
}

type ResourceService

type ResourceService interface {
	FetchResourceTree(appName string) (*Items, error)
	FetchPodContainerLogs(appName string, podName string, req PodContainerLogReq) (*Items, error)
}

type ResourceServiceImpl

type ResourceServiceImpl struct {
	*ArgoSession
	// contains filtered or unexported fields
}

func NewResourceServiceImpl

func NewResourceServiceImpl(session *ArgoSession) *ResourceServiceImpl

func (*ResourceServiceImpl) FetchPodContainerLogs

func (impl *ResourceServiceImpl) FetchPodContainerLogs(appName string, podName string, req PodContainerLogReq) (*Items, error)

func (*ResourceServiceImpl) FetchResourceTree

func (impl *ResourceServiceImpl) FetchResourceTree(appName string) (*Items, error)

type StatusCode

type StatusCode int

func (StatusCode) IsSuccess

func (code StatusCode) IsSuccess() bool