Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Module cli.Command = cli.Command{ Name: "provisiond", Usage: "handles reservations streams and use other daemon to deploy them", Flags: []cli.Flag{ &cli.StringFlag{ Name: "root", Usage: "`ROOT` working directory of the module", Value: "/var/cache/modules/provisiond", }, &cli.StringFlag{ Name: "broker", Usage: "connection string to the message `BROKER`", Value: "unix:///var/run/redis.sock", }, &cli.BoolFlag{ Name: "integrity", Usage: "run some integrity checks on some files", }, }, Action: action, }
Module entry point
Functions ¶
func ReportChecks ¶
Types ¶
type CapacitySetter ¶
type CapacitySetter struct {
// contains filtered or unexported fields
}
func NewCapacitySetter ¶
func NewCapacitySetter(substrateGateway *stubs.SubstrateGatewayStub, storage provision.Storage) CapacitySetter
func (*CapacitySetter) Callback ¶
func (c *CapacitySetter) Callback(twin uint32, contract uint64, delete bool)
func (*CapacitySetter) Set ¶
func (c *CapacitySetter) Set(deployment ...gridtypes.Deployment) error
type ContractEventHandler ¶
type ContractEventHandler struct {
// contains filtered or unexported fields
}
func NewContractEventHandler ¶
func NewContractEventHandler(node uint32, substrateGateway *stubs.SubstrateGatewayStub, engine provision.Engine, events *events.RedisConsumer) ContractEventHandler
type DeploymentID ¶
type Report ¶
type Report struct {
Consumption []substrate.NruConsumption
}
type Reporter ¶
type Reporter struct {
// contains filtered or unexported fields
}
Reporter structure
func NewReporter ¶
NewReporter creates a new capacity reporter
Click to show internal directories.
Click to hide internal directories.