manifest

Documentation

Index

• Variables
• type Client
• type Service
  • func NewService(ctx context.Context, session session.Session, bus pubsub.Bus, ...) (Service, error)
• type ServiceConfig
• type Status
• type StatusClient

Variables

var (
	// ErrShutdownTimerExpired for a terminating deployment
	ErrShutdownTimerExpired = errors.New("shutdown timer expired")
	// ErrManifestVersion indicates that the given manifest's version does not
	// match the blockchain Version value.
	ErrManifestVersion = errors.New("manifest version validation failed")
)

var ErrNoLeaseForDeployment = errors.New("no lease for deployment")

var ErrNotRunning = errors.New("not running")

ErrNotRunning is the error when service is not running

Types

type Client

type Client interface {
	Submit(context.Context, dtypes.DeploymentID, manifest.Manifest) error
}

Handler is the interface that wraps HandleManifest method

type Service

type Service interface {
	StatusClient
	Client
	Done() <-chan struct{}
}

Service is the interface that includes StatusClient and Handler interfaces. It also wraps Done method

func NewService

func NewService(ctx context.Context, session session.Session, bus pubsub.Bus, hostnameService cluster.HostnameServiceClient, cfg ServiceConfig) (Service, error)

NewHandler creates and returns new Service instance Manage incoming leases and manifests and pair the two together to construct and emit a ManifestReceived event.

type ServiceConfig

type ServiceConfig struct {
	HTTPServicesRequireAtLeastOneHost bool
}

type Status

type Status struct {
	Deployments uint32 `json:"deployments"`
}

Status is the data structure

type StatusClient

type StatusClient interface {
	Status(context.Context) (*Status, error)
}

StatusClient is the interface which includes status of service