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 ¶
type Client interface {
Submit(context.Context, dtypes.DeploymentID, manifest.Manifest) error
IsActive(context.Context, dtypes.DeploymentID) (bool, 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 ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.