utils

Documentation

Index

• func GetK8sClient() (client.Client, error)
• func IsDeployReady(ctx context.Context, c client.Client, name, namespace string) wait.ConditionFunc
• func IsPodReady(ctx context.Context, c client.Client, podName, namespace string) wait.ConditionFunc
• func IsPodRunning(ctx context.Context, c client.Client, podName, namespace string) wait.ConditionFunc
• func NewSpinner(text string) *pterm.SpinnerPrinter
• func WaitAPIServiceReady(ctx context.Context, client client.Client) error
• func WaitForDeploymentReady(ctx context.Context, k8sClient client.Client, namespace string, name string, ...) error
• func WaitForPodsReady(ctx context.Context, k8sClient client.Client, namespace string, name string, ...) error
• type ErrorResponse
• type GithubClient
  • func NewGithubClient(apiKey string, httpClient *http.Client) (*GithubClient, error)
  • func (c *GithubClient) Do(req *http.Request, v interface{}) (*ErrorResponse, error)
  • func (c *GithubClient) DoRequest(method, path string, body, v interface{}) (*ErrorResponse, error)
  • func (c *GithubClient) GetLatest() (string, error)
  • func (c *GithubClient) GetTags() ([]Tag, *ErrorResponse, error)
  • func (c *GithubClient) NewRequest(method, path string, body interface{}) (*http.Request, error)
• type Obj
• type Tag

Functions

func GetK8sClient

func GetK8sClient() (client.Client, error)

func IsDeployReady

func IsDeployReady(ctx context.Context, c client.Client, name, namespace string) wait.ConditionFunc

IsPodReady check if the pod in question is running state

func IsPodReady

func IsPodReady(ctx context.Context, c client.Client, podName, namespace string) wait.ConditionFunc

IsPodReady check if the pod in question is running state

func IsPodRunning

func IsPodRunning(ctx context.Context, c client.Client, podName, namespace string) wait.ConditionFunc

IsPodRunning check if the pod in question is running state

func NewSpinner

func NewSpinner(text string) *pterm.SpinnerPrinter

NewSpinner ...

func WaitAPIServiceReady

func WaitAPIServiceReady(ctx context.Context, client client.Client) error

func WaitForDeploymentReady

func WaitForDeploymentReady(ctx context.Context, k8sClient client.Client, namespace string, name string, timeout time.Duration) error

func WaitForPodsReady

func WaitForPodsReady(ctx context.Context, k8sClient client.Client, namespace string, name string, timeout time.Duration, bylabel string) error

Types

type ErrorResponse

type ErrorResponse struct {
	StatusCode int
	Errors     string
}

type GithubClient

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

func NewGithubClient

func NewGithubClient(apiKey string, httpClient *http.Client) (*GithubClient, error)

func (*GithubClient) Do

func (c *GithubClient) Do(req *http.Request, v interface{}) (*ErrorResponse, error)

func (*GithubClient) DoRequest

func (c *GithubClient) DoRequest(method, path string, body, v interface{}) (*ErrorResponse, error)

func (*GithubClient) GetLatest

func (c *GithubClient) GetLatest() (string, error)

func (*GithubClient) GetTags

func (c *GithubClient) GetTags() ([]Tag, *ErrorResponse, error)

func (*GithubClient) NewRequest

func (c *GithubClient) NewRequest(method, path string, body interface{}) (*http.Request, error)

type Obj

type Obj struct {
	SHA   string `json:"sha,omitempty"`
	TType string `json:"type,omitempty"`
	URL   string `json:"url,omitempty"`
}

type Tag

type Tag struct {
	Ref    string `json:"ref,omitempty"`
	NodeID string `json:"node_id,omitempty"`
	URL    string `json:"url,omitempty"`
	Object Obj    `json:"object,omitempty"`
}