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 ¶
func ManifestSubmitErrorToHTTP ¶ added in v0.11.2
ManifestSubmitErrorToHTTP maps manifest submit errors to HttpError for gateway responses.
Types ¶
type Client ¶
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{}
Close() error
}
Service is the interface that includes StatusClient and Handler interfaces. It also wraps Done and Close methods
func NewService ¶
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 ¶
type StatusClient ¶
type StatusClient interface {
Status(context.Context) (*apclient.ManifestStatus, error)
StatusV1(context.Context) (*provider.ManifestStatus, error)
}
StatusClient is the interface which includes status of service
Source Files
Click to show internal directories.
Click to hide internal directories.