flux: github.com/weaveworks/flux/pkg/remote Index | Files | Directories

package remote

import "github.com/weaveworks/flux/pkg/remote"

Index

Package Files

doc.go errors.go logging.go metrics.go mock.go

func ClusterError Uses

func ClusterError(err error) error

func Instrument Uses

func Instrument(s api.Server) *instrumentedServer

func ServerTestBattery Uses

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

func UnavailableError Uses

func UnavailableError(err error) error

func UnsupportedResourceKind Uses

func UnsupportedResourceKind(err error) error

func UpgradeNeededError Uses

func UpgradeNeededError(err error) error

type ErrorLoggingServer Uses

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

func NewErrorLoggingServer Uses

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

func (*ErrorLoggingServer) Export Uses

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

func (*ErrorLoggingServer) GitRepoConfig Uses

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

func (*ErrorLoggingServer) JobStatus Uses

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

func (*ErrorLoggingServer) ListImages Uses

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

func (*ErrorLoggingServer) ListImagesWithOptions Uses

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

func (*ErrorLoggingServer) ListServices Uses

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

func (*ErrorLoggingServer) ListServicesWithOptions Uses

func (p *ErrorLoggingServer) ListServicesWithOptions(ctx context.Context, opts v11.ListServicesOptions) (_ []v6.ControllerStatus, err error)

func (*ErrorLoggingServer) NotifyChange Uses

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

func (*ErrorLoggingServer) Ping Uses

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

func (*ErrorLoggingServer) SyncStatus Uses

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

func (*ErrorLoggingServer) UpdateManifests Uses

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

func (*ErrorLoggingServer) Version Uses

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

type FatalError Uses

type FatalError struct {
    Err error
}

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

func (FatalError) Error Uses

func (err FatalError) Error() string

type MockServer Uses

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 Uses

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

func (*MockServer) GitRepoConfig Uses

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

func (*MockServer) JobStatus Uses

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

func (*MockServer) ListImages Uses

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

func (*MockServer) ListImagesWithOptions Uses

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

func (*MockServer) ListServices Uses

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

func (*MockServer) ListServicesWithOptions Uses

func (p *MockServer) ListServicesWithOptions(context.Context, v11.ListServicesOptions) ([]v6.ControllerStatus, error)

func (*MockServer) NotifyChange Uses

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

func (*MockServer) Ping Uses

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

func (*MockServer) SyncStatus Uses

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

func (*MockServer) UpdateManifests Uses

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

func (*MockServer) Version Uses

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

Directories

PathSynopsis
rpcThis is a `net/rpc`-compatible implementation of a client and server for `flux/api.Server`.

Package remote imports 21 packages (graph). Updated 2020-04-27. Refresh now. Tools for package owners.