app

type AppConfigFile struct {
	// App describes a ksonnet application.
	App kstypes.AppConfig
}

type ApplyIamRequest struct {
	Project string `json:"project"`
	Cluster string `json:"cluster"`
	Email   string `json:"email"`
	Token   string `json:"token"`
	Action  string `json:"action"`
}

type BasicAuth struct {
	Username string `json:"username,omitempty"`
	// Encoded password
	Password string `json:"password,omitempty"`
}

type C2DRequest struct {
	//ConfigFile URL
	ConfigFile string `json:"configFile,omitempty"`

	// GCP Project Id
	Project string `json:"project,omitempty"`

	// deploy Name
	Name string `json:"name,omitempty"`

	// user email
	Email string `json:"email,omitempty"`

	EndpointConfig EndpointConfig `json:"endpointConfig,omitempty"`

	// GKE Zone
	Zone string `json:"zone,omitempty"`

	// kubeflow Version
	Version string `json:"version,omitempty"`

	ShareAnonymousUsage bool `json:"shareAnonymousUsage,omitempty"`

	SkipInitProject bool `json:"skipInitProject,omitempty"`

	// Temporary service account access Token
	Token string `json:"token,omitempty"`
}

type CreateResponse struct {
}

type DmConf struct {
	Imports   interface{} `json:"imports"`
	Resources []Resource  `json:"resources"`
}

type DmSpec struct {
	// path to the deployment manager configuration file
	ConfigFile string
	// path to the deployment manager template file
	TemplateFile string
	// the suffix to append to the deployment name
	DmNameSuffix string
}

type EndpointConfig struct {
	BasicAuth BasicAuth `json:"basicAuth,omitempty"`
	IAP       IAP       `json:"iap,omitempty"`
}

type GcService interface {
	StartGC() error
}

type HealthzRequest struct {
	Msg string
}

type HealthzResponse struct {
	Reply string
}

type IAP struct {
	OAuthClientId     string `json:"oAuthClientId,omitempty"`
	OAuthClientSecret string `json:"oAuthClientSecret,omitempty"`
}

type IamBinding struct {
	Members []string `type:"members"`
	Roles   []string `type:"roles"`
}

type IamConf struct {
	IamBindings []IamBinding `json:"bindings"`
}

type InitProjectRequest struct {
	Project       string
	ProjectNumber string
	Token         string
}

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

type KfctlServiceV1Beta1 interface {
	// CreateCreateDeployment creates a Kubeflow deployment
	CreateDeployment(context.Context, kfdefsv1beta1.KfDef) (*kfdefsv1beta1.KfDef, error)
	// GetLatestKfdef returns latest KfDef copy which include deployment status
	GetLatestKfDef(kfdefsv1beta1.KfDef) (*kfdefsv1beta1.KfDef, error)
}

type KsService interface {
	// Apply ksonnet app to target GKE cluster
	BindRole(context.Context, string, string, string) error
	ApplyIamPolicy(context.Context, ApplyIamRequest) error
	GetProjectLock(string) *sync.Mutex
}

type LibrarySpec struct {
	Version string
	Path    string
}

type MultiError struct {
	Errors []error
}

type ProjectAccessChecker func(string, oauth2.TokenSource) (bool, error)

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

type Resource struct {
	Name       string                 `json:"name"`
	Type       string                 `json:"type"`
	Properties map[string]interface{} `json:"properties"`
}

type RouterService interface {
	// CreateCreateDeployment creates a Kubeflow deployment
	CreateDeployment(context.Context, C2DRequest) (*kfdefs.KfDef, error)
}

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

type TokenRefresher interface {
	Refresh(newToken oauth2.Token) error
	Token() (*oauth2.Token, error)
}