kaws

Documentation

Index

• type Provider
  • func FromEnv() (*Provider, error)
  • func (p *Provider) AppCreate(name string, opts structs.AppCreateOptions) (*structs.App, error)
  • func (p *Provider) AppDelete(name string) error
  • func (p *Provider) AppIdles(name string) (bool, error)
  • func (p *Provider) AppLogs(name string, opts structs.LogsOptions) (io.ReadCloser, error)
  • func (p *Provider) AppStatus(name string) (string, error)
  • func (p *Provider) BuildExport(app, id string, w io.Writer) error
  • func (p *Provider) BuildImport(app string, r io.Reader) (*structs.Build, error)
  • func (p *Provider) BuildLogs(app, id string, opts structs.LogsOptions) (io.ReadCloser, error)
  • func (p *Provider) DeploymentTimeout() int
  • func (p *Provider) Initialize(opts structs.ProviderOptions) error
  • func (p *Provider) InstanceList() (structs.Instances, error)
  • func (p *Provider) Log(app, stream string, ts time.Time, message string) error
  • func (p *Provider) ObjectDelete(app, key string) error
  • func (p *Provider) ObjectExists(app, key string) (bool, error)
  • func (p *Provider) ObjectFetch(app, key string) (io.ReadCloser, error)
  • func (p *Provider) ObjectList(app, prefix string) ([]string, error)
  • func (p *Provider) ObjectStore(app, key string, r io.Reader, opts structs.ObjectStoreOptions) (*structs.Object, error)
  • func (p *Provider) ProcessLogs(app, pid string, opts structs.LogsOptions) (io.ReadCloser, error)
  • func (p *Provider) RenderTemplate(name string, params map[string]interface{}) ([]byte, error)
  • func (p *Provider) RepositoryAuth(app string) (string, string, error)
  • func (p *Provider) RepositoryHost(app string) (string, bool, error)
  • func (p *Provider) Resolver() (string, error)
  • func (p *Provider) ResourceRender(app string, r manifest.Resource) ([]byte, error)
  • func (p *Provider) ServiceHost(app string, s manifest.Service) string
  • func (p *Provider) Sync(name string) error
  • func (p *Provider) SystemHost() string
  • func (p *Provider) SystemInstall(w io.Writer, opts structs.SystemInstallOptions) (string, error)
  • func (p *Provider) SystemJwtSignKey() (string, error)
  • func (p *Provider) SystemJwtSignKeyRotate() (string, error)
  • func (p *Provider) SystemLogs(opts structs.LogsOptions) (io.ReadCloser, error)
  • func (p *Provider) SystemStatus() (string, error)
  • func (p *Provider) SystemTemplate(version string) ([]byte, error)
  • func (p *Provider) SystemUninstall(name string, w io.Writer, opts structs.SystemUninstallOptions) error
  • func (p *Provider) SystemUpdate(opts structs.SystemUpdateOptions) error
  • func (p *Provider) WithContext(ctx context.Context) structs.Provider
• type StackController
  • func NewStackController(p *Provider) (*StackController, error)
  • func (c *StackController) Add(obj interface{}) error
  • func (c *StackController) Client() kubernetes.Interface
  • func (c *StackController) Delete(obj interface{}) error
  • func (c *StackController) ListOptions(opts *am.ListOptions)
  • func (c *StackController) Run()
  • func (c *StackController) Start() error
  • func (c *StackController) Stop() error
  • func (c *StackController) Update(prev, cur interface{}) error

Types

type Provider

type Provider struct {
	*k8s.Provider

	AccountId      string
	AdminUser      string
	AutoscalerRole string
	// BalancerSecurity     string
	BaseDomain    string
	Bucket        string
	Cluster       string
	EventQueue    string
	EventTopic    string
	NodesRole     string
	Region        string
	RackRole      string
	RouterCache   string
	RouterHosts   string
	RouterRole    string
	RouterTargets string
	// RouterTargetGroup80  string
	// RouterTargetGroup443 string
	StackId string

	CloudFormation cloudformationiface.CloudFormationAPI
	CloudWatchLogs cloudwatchlogsiface.CloudWatchLogsAPI
	ECR            ecriface.ECRAPI
	S3             s3iface.S3API
	SQS            sqsiface.SQSAPI
	// contains filtered or unexported fields
}

func FromEnv

func FromEnv() (*Provider, error)

func (*Provider) AppCreate

func (p *Provider) AppCreate(name string, opts structs.AppCreateOptions) (*structs.App, error)

func (*Provider) AppDelete

func (p *Provider) AppDelete(name string) error

func (*Provider) AppIdles

func (p *Provider) AppIdles(name string) (bool, error)

func (*Provider) AppLogs

func (p *Provider) AppLogs(name string, opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) AppStatus

func (p *Provider) AppStatus(name string) (string, error)

func (*Provider) BuildExport

func (p *Provider) BuildExport(app, id string, w io.Writer) error

func (*Provider) BuildImport

func (p *Provider) BuildImport(app string, r io.Reader) (*structs.Build, error)

func (*Provider) BuildLogs

func (p *Provider) BuildLogs(app, id string, opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) DeploymentTimeout

func (p *Provider) DeploymentTimeout() int

func (*Provider) Initialize

func (p *Provider) Initialize(opts structs.ProviderOptions) error

func (*Provider) InstanceList

func (p *Provider) InstanceList() (structs.Instances, error)

func (*Provider) Log

func (p *Provider) Log(app, stream string, ts time.Time, message string) error

func (*Provider) ObjectDelete

func (p *Provider) ObjectDelete(app, key string) error

func (*Provider) ObjectExists

func (p *Provider) ObjectExists(app, key string) (bool, error)

func (*Provider) ObjectFetch

func (p *Provider) ObjectFetch(app, key string) (io.ReadCloser, error)

ObjectFetch fetches an Object

func (*Provider) ObjectList

func (p *Provider) ObjectList(app, prefix string) ([]string, error)

func (*Provider) ObjectStore

func (p *Provider) ObjectStore(app, key string, r io.Reader, opts structs.ObjectStoreOptions) (*structs.Object, error)

ObjectStore stores an Object

func (*Provider) ProcessLogs

func (p *Provider) ProcessLogs(app, pid string, opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) RenderTemplate

func (p *Provider) RenderTemplate(name string, params map[string]interface{}) ([]byte, error)

func (*Provider) RepositoryAuth

func (p *Provider) RepositoryAuth(app string) (string, string, error)

func (*Provider) RepositoryHost

func (p *Provider) RepositoryHost(app string) (string, bool, error)

func (*Provider) Resolver

func (p *Provider) Resolver() (string, error)

func (*Provider) ResourceRender

func (p *Provider) ResourceRender(app string, r manifest.Resource) ([]byte, error)

func (*Provider) ServiceHost

func (p *Provider) ServiceHost(app string, s manifest.Service) string

func (*Provider) Sync

func (p *Provider) Sync(name string) error

func (*Provider) SystemHost

func (p *Provider) SystemHost() string

func (*Provider) SystemInstall

func (p *Provider) SystemInstall(w io.Writer, opts structs.SystemInstallOptions) (string, error)

func (*Provider) SystemJwtSignKey

func (p *Provider) SystemJwtSignKey() (string, error)

func (*Provider) SystemJwtSignKeyRotate

func (p *Provider) SystemJwtSignKeyRotate() (string, error)

func (*Provider) SystemLogs

func (p *Provider) SystemLogs(opts structs.LogsOptions) (io.ReadCloser, error)

func (*Provider) SystemStatus

func (p *Provider) SystemStatus() (string, error)

func (*Provider) SystemTemplate

func (p *Provider) SystemTemplate(version string) ([]byte, error)

func (*Provider) SystemUninstall

func (p *Provider) SystemUninstall(name string, w io.Writer, opts structs.SystemUninstallOptions) error

func (*Provider) SystemUpdate

func (p *Provider) SystemUpdate(opts structs.SystemUpdateOptions) error

func (*Provider) WithContext

func (p *Provider) WithContext(ctx context.Context) structs.Provider

type StackController

type StackController struct {
	Controller *kctl.Controller
	Provider   *Provider
}

func NewStackController

func NewStackController(p *Provider) (*StackController, error)

func (*StackController) Add

func (c *StackController) Add(obj interface{}) error

func (*StackController) Client

func (c *StackController) Client() kubernetes.Interface

func (*StackController) Delete

func (c *StackController) Delete(obj interface{}) error

func (*StackController) ListOptions

func (c *StackController) ListOptions(opts *am.ListOptions)

func (*StackController) Run

func (c *StackController) Run()

func (*StackController) Start

func (c *StackController) Start() error

func (*StackController) Stop

func (c *StackController) Stop() error

func (*StackController) Update

func (c *StackController) Update(prev, cur interface{}) error