local

Documentation

Index

• Constants
• type BucketFunc
• type Provider
  • func FromEnv() (*Provider, 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) BuildLogs(app, id string, opts structs.LogsOptions) (io.ReadCloser, error)
  • func (p *Provider) DeleteDB(resource string) error
  • func (p *Provider) Initialize(opts structs.ProviderOptions) error
  • func (p *Provider) IsDBSnapshotComplete(snapshot string) (bool, error)
  • func (p *Provider) Log(app, stream string, ts time.Time, message string) 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) ResourceGet(app, name string) (*structs.Resource, error)
  • func (p *Provider) ResourceList(app string) (structs.Resources, 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) SetDBDeletionProtectionAndCreateSnapShot(app, resource, snapshot string) (string, error)
  • 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) 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
  • func (p *Provider) Workers() error
• type Storage
  • func NewStorage(file string) (*Storage, error)
  • func (s *Storage) Clear(prefix string) error
  • func (s *Storage) List(prefix string) ([]string, error)
  • func (s *Storage) Load(key string, v interface{}) error
  • func (s *Storage) Read(key string) ([]byte, error)
  • func (s *Storage) Write(key string, v interface{}) error

Constants

const (
	RootBucket = "root"
)

Types

type BucketFunc

type BucketFunc func(*bolt.Bucket) error

type Provider

type Provider struct {
	*k8s.Provider

	DNS      string
	Platform string
	// contains filtered or unexported fields
}

func FromEnv

func FromEnv() (*Provider, 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) BuildLogs

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

func (*Provider) DeleteDB

func (p *Provider) DeleteDB(resource string) error

func (*Provider) Initialize

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

func (*Provider) IsDBSnapshotComplete

func (p *Provider) IsDBSnapshotComplete(snapshot string) (bool, error)

func (*Provider) Log

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

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) ResourceGet

func (p *Provider) ResourceGet(app, name string) (*structs.Resource, error)

func (*Provider) ResourceList

func (p *Provider) ResourceList(app string) (structs.Resources, 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) SetDBDeletionProtectionAndCreateSnapShot

func (p *Provider) SetDBDeletionProtectionAndCreateSnapShot(app, resource, snapshot string) (string, error)

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) 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

func (*Provider) Workers

func (p *Provider) Workers() error

type Storage

type Storage struct {
	File string
	// contains filtered or unexported fields
}

func NewStorage

func NewStorage(file string) (*Storage, error)

func (*Storage) Clear

func (s *Storage) Clear(prefix string) error

func (*Storage) List

func (s *Storage) List(prefix string) ([]string, error)

func (*Storage) Load

func (s *Storage) Load(key string, v interface{}) error

func (*Storage) Read

func (s *Storage) Read(key string) ([]byte, error)

func (*Storage) Write

func (s *Storage) Write(key string, v interface{}) error