cloud

Documentation

Index

• Variables
• func WriteSnapshotTo(ctx context.Context, snapshot *proto_webview.Snapshot, w io.Writer) error
• type CloudStatusManager
  • func NewStatusManager(client HttpClient, clock clockwork.Clock) *CloudStatusManager
  • func (c *CloudStatusManager) CheckStatus(ctx context.Context, st store.RStore, cloudAddress string, ...)
  • func (c *CloudStatusManager) OnChange(ctx context.Context, st store.RStore, _ store.ChangeSummary) error
• type HttpClient
  • func ProvideHttpClient() HttpClient
• type Snapshotter
  • func NewSnapshotter(st store.RStore, client ctrlclient.Client) *Snapshotter
  • func (s *Snapshotter) WriteSnapshot(ctx context.Context, path string)

Variables

var WireSet = wire.NewSet(
	ProvideHttpClient,
	NewStatusManager)

Functions

func WriteSnapshotTo

func WriteSnapshotTo(ctx context.Context, snapshot *proto_webview.Snapshot, w io.Writer) error

Types

type CloudStatusManager

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

func NewStatusManager

func NewStatusManager(client HttpClient, clock clockwork.Clock) *CloudStatusManager

func (*CloudStatusManager) CheckStatus

func (c *CloudStatusManager) CheckStatus(ctx context.Context, st store.RStore, cloudAddress string, requestKey statusRequestKey)

func (*CloudStatusManager) OnChange

func (c *CloudStatusManager) OnChange(ctx context.Context, st store.RStore, _ store.ChangeSummary) error

type HttpClient

type HttpClient interface {
	Do(req *http.Request) (*http.Response, error)
}

func ProvideHttpClient

func ProvideHttpClient() HttpClient

type Snapshotter

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

func NewSnapshotter

func NewSnapshotter(st store.RStore, client ctrlclient.Client) *Snapshotter

func (*Snapshotter) WriteSnapshot

func (s *Snapshotter) WriteSnapshot(ctx context.Context, path string)