manifest

Documentation

Index

• Variables
• func AllHostnamesOfManifestGroup(mgroup maniv2beta1.Group) []string
• func IngressHost(lid mtypes.LeaseID, svcName string) string
• 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")
	ErrNoManifestForDeployment = errors.New("manifest not yet received for that deployment")
	ErrNoLeaseForDeployment    = errors.New("no lease for deployment")
)

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

ErrNotRunning is the error when service is not running

Functions

func AllHostnamesOfManifestGroup

func AllHostnamesOfManifestGroup(mgroup maniv2beta1.Group) []string

func IngressHost

func IngressHost(lid mtypes.LeaseID, svcName string) string

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{}
}

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 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 ServiceConfig struct {
	HTTPServicesRequireAtLeastOneHost bool
	ManifestTimeout                   time.Duration
	RPCQueryTimeout                   time.Duration
	CachedResultMaxAge                time.Duration
}

type Status

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

Status is the data structure

type StatusClient

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

StatusClient is the interface which includes status of service