Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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") ErrNoManifestForDeployment = errors.New("manifest not yet received for that deployment") ErrNoLeaseForDeployment = errors.New("no lease for deployment") )
View Source
var ErrNotRunning = errors.New("not running")
ErrNotRunning is the error when service is not running
Functions ¶
This section is empty.
Types ¶
type Client ¶ added in v0.7.3
type Client interface { Submit(context.Context, dtypes.DeploymentID, manifest.Manifest) error IsActive(context.Context, dtypes.DeploymentID) (bool, error) }
Client 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 ¶ added in v0.7.3
func NewService(ctx context.Context, session session.Session, bus pubsub.Bus, hostnameService clustertypes.HostnameServiceClient, cfg ServiceConfig) (Service, error)
NewService 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 ¶ added in v0.9.3
Click to show internal directories.
Click to hide internal directories.