remote

Documentation

Index

• func ClusterError(err error) error
• func Instrument(s api.Server) *instrumentedServer
• func InstrumentUpstream(s api.UpstreamServer) *instrumentedUpstreamServer
• func ServerTestBattery(t *testing.T, wrap func(mock api.UpstreamServer) api.UpstreamServer)
• func UnavailableError(err error) error
• func UnsupportedResourceKind(err error) error
• func UpgradeNeededError(err error) error
• type ErrorLoggingServer
  • func NewErrorLoggingServer(s api.Server, l log.Logger) *ErrorLoggingServer
  • func (p *ErrorLoggingServer) Export(ctx context.Context) (config []byte, err error)
  • func (p *ErrorLoggingServer) GitRepoConfig(ctx context.Context, regenerate bool) (_ v6.GitConfig, err error)
  • func (p *ErrorLoggingServer) JobStatus(ctx context.Context, jobID job.ID) (_ job.Status, err error)
  • func (p *ErrorLoggingServer) ListImages(ctx context.Context, spec update.ResourceSpec) (_ []v6.ImageStatus, err error)
  • func (p *ErrorLoggingServer) ListImagesWithOptions(ctx context.Context, opts v10.ListImagesOptions) (_ []v6.ImageStatus, err error)
  • func (p *ErrorLoggingServer) ListServices(ctx context.Context, maybeNamespace string) (_ []v6.ControllerStatus, err error)
  • func (p *ErrorLoggingServer) SyncStatus(ctx context.Context, ref string) (_ []string, err error)
  • func (p *ErrorLoggingServer) UpdateManifests(ctx context.Context, u update.Spec) (_ job.ID, err error)
• type ErrorLoggingUpstreamServer
  • func NewErrorLoggingUpstreamServer(s api.UpstreamServer, l log.Logger) *ErrorLoggingUpstreamServer
  • func (p *ErrorLoggingUpstreamServer) NotifyChange(ctx context.Context, change v9.Change) (err error)
  • func (p *ErrorLoggingUpstreamServer) Ping(ctx context.Context) (err error)
  • func (p *ErrorLoggingUpstreamServer) Version(ctx context.Context) (v string, err error)
• type FatalError
  • func (err FatalError) Error() string
• type MockServer
  • func (p *MockServer) Export(ctx context.Context) ([]byte, error)
  • func (p *MockServer) GitRepoConfig(ctx context.Context, regenerate bool) (v6.GitConfig, error)
  • func (p *MockServer) JobStatus(context.Context, job.ID) (job.Status, error)
  • func (p *MockServer) ListImages(context.Context, update.ResourceSpec) ([]v6.ImageStatus, error)
  • func (p *MockServer) ListImagesWithOptions(context.Context, v10.ListImagesOptions) ([]v6.ImageStatus, error)
  • func (p *MockServer) ListServices(ctx context.Context, ns string) ([]v6.ControllerStatus, error)
  • func (p *MockServer) NotifyChange(ctx context.Context, change v9.Change) error
  • func (p *MockServer) Ping(ctx context.Context) error
  • func (p *MockServer) SyncStatus(context.Context, string) ([]string, error)
  • func (p *MockServer) UpdateManifests(ctx context.Context, s update.Spec) (job.ID, error)
  • func (p *MockServer) Version(ctx context.Context) (string, error)

Functions

func ClusterError

func ClusterError(err error) error

func Instrument

func Instrument(s api.Server) *instrumentedServer

func InstrumentUpstream

func InstrumentUpstream(s api.UpstreamServer) *instrumentedUpstreamServer

func ServerTestBattery

func ServerTestBattery(t *testing.T, wrap func(mock api.UpstreamServer) api.UpstreamServer)

func UnavailableError

func UnavailableError(err error) error

func UnsupportedResourceKind

func UnsupportedResourceKind(err error) error

func UpgradeNeededError

func UpgradeNeededError(err error) error

Types

type ErrorLoggingServer

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

func NewErrorLoggingServer

func NewErrorLoggingServer(s api.Server, l log.Logger) *ErrorLoggingServer

func (*ErrorLoggingServer) Export

func (p *ErrorLoggingServer) Export(ctx context.Context) (config []byte, err error)

func (*ErrorLoggingServer) GitRepoConfig

func (p *ErrorLoggingServer) GitRepoConfig(ctx context.Context, regenerate bool) (_ v6.GitConfig, err error)

func (*ErrorLoggingServer) JobStatus

func (p *ErrorLoggingServer) JobStatus(ctx context.Context, jobID job.ID) (_ job.Status, err error)

func (*ErrorLoggingServer) ListImages

func (p *ErrorLoggingServer) ListImages(ctx context.Context, spec update.ResourceSpec) (_ []v6.ImageStatus, err error)

func (*ErrorLoggingServer) ListImagesWithOptions

func (p *ErrorLoggingServer) ListImagesWithOptions(ctx context.Context, opts v10.ListImagesOptions) (_ []v6.ImageStatus, err error)

func (*ErrorLoggingServer) ListServices

func (p *ErrorLoggingServer) ListServices(ctx context.Context, maybeNamespace string) (_ []v6.ControllerStatus, err error)

func (*ErrorLoggingServer) SyncStatus

func (p *ErrorLoggingServer) SyncStatus(ctx context.Context, ref string) (_ []string, err error)

func (*ErrorLoggingServer) UpdateManifests

func (p *ErrorLoggingServer) UpdateManifests(ctx context.Context, u update.Spec) (_ job.ID, err error)

type ErrorLoggingUpstreamServer

type ErrorLoggingUpstreamServer struct {
	*ErrorLoggingServer
	// contains filtered or unexported fields
}

func NewErrorLoggingUpstreamServer

func NewErrorLoggingUpstreamServer(s api.UpstreamServer, l log.Logger) *ErrorLoggingUpstreamServer

func (*ErrorLoggingUpstreamServer) NotifyChange

func (p *ErrorLoggingUpstreamServer) NotifyChange(ctx context.Context, change v9.Change) (err error)

func (*ErrorLoggingUpstreamServer) Ping

func (p *ErrorLoggingUpstreamServer) Ping(ctx context.Context) (err error)

func (*ErrorLoggingUpstreamServer) Version

func (p *ErrorLoggingUpstreamServer) Version(ctx context.Context) (v string, err error)

type FatalError

type FatalError struct {
	Err error
}

Wrap errors in this to indicate that the server should be considered dead, and disconnected.

func (FatalError) Error

func (err FatalError) Error() string

type MockServer

type MockServer struct {
	PingError error

	VersionAnswer string
	VersionError  error

	ExportAnswer []byte
	ExportError  error

	ListServicesAnswer []v6.ControllerStatus
	ListServicesError  error

	ListImagesAnswer []v6.ImageStatus
	ListImagesError  error

	UpdateManifestsArgTest func(update.Spec) error
	UpdateManifestsAnswer  job.ID
	UpdateManifestsError   error

	NotifyChangeError error

	SyncStatusAnswer []string
	SyncStatusError  error

	JobStatusAnswer job.Status
	JobStatusError  error

	GitRepoConfigAnswer v6.GitConfig
	GitRepoConfigError  error
}

func (*MockServer) Export

func (p *MockServer) Export(ctx context.Context) ([]byte, error)

func (*MockServer) GitRepoConfig

func (p *MockServer) GitRepoConfig(ctx context.Context, regenerate bool) (v6.GitConfig, error)

func (*MockServer) JobStatus

func (p *MockServer) JobStatus(context.Context, job.ID) (job.Status, error)

func (*MockServer) ListImages

func (p *MockServer) ListImages(context.Context, update.ResourceSpec) ([]v6.ImageStatus, error)

func (*MockServer) ListImagesWithOptions

func (p *MockServer) ListImagesWithOptions(context.Context, v10.ListImagesOptions) ([]v6.ImageStatus, error)

func (*MockServer) ListServices

func (p *MockServer) ListServices(ctx context.Context, ns string) ([]v6.ControllerStatus, error)

func (*MockServer) NotifyChange

func (p *MockServer) NotifyChange(ctx context.Context, change v9.Change) error

func (*MockServer) Ping

func (p *MockServer) Ping(ctx context.Context) error

func (*MockServer) SyncStatus

func (p *MockServer) SyncStatus(context.Context, string) ([]string, error)

func (*MockServer) UpdateManifests

func (p *MockServer) UpdateManifests(ctx context.Context, s update.Spec) (job.ID, error)

func (*MockServer) Version

func (p *MockServer) Version(ctx context.Context) (string, error)