Documentation
¶
Overview ¶
Package core provides transport-agnostic implementation of Migrillian tool.
Index ¶
- func LoadConfigFromFile(filename string) (*configpb.MigrillianConfig, error)
- func RunMigration(ctx context.Context, ctrls []*Controller)
- func ValidateConfig(cfg *configpb.MigrillianConfig) error
- func ValidateMigrationConfig(cfg *configpb.MigrationConfig) error
- type Controller
- type Options
- type PreorderedLogClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LoadConfigFromFile ¶ added in v1.0.21
func LoadConfigFromFile(filename string) (*configpb.MigrillianConfig, error)
LoadConfigFromFile reads MigrillianConfig from the given filename, which should contain text-protobuf encoded configuration data.
func RunMigration ¶ added in v1.0.21
func RunMigration(ctx context.Context, ctrls []*Controller)
RunMigration migrates data from a number of CT logs to Trillian. Each log's migration is coordinated by the corresponding Controller. This function terminates when all Controllers are done (possibly with an error, or as a result of canceling the passed in context).
func ValidateConfig ¶ added in v1.0.21
func ValidateConfig(cfg *configpb.MigrillianConfig) error
ValidateConfig verifies that MigrillianConfig is correct. In particular: - Migration configs are valid (as per ValidateMigrationConfig). - Each migration config has a unique log ID.
func ValidateMigrationConfig ¶ added in v1.0.21
func ValidateMigrationConfig(cfg *configpb.MigrationConfig) error
ValidateMigrationConfig verifies that the migration config is sane.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller coordinates migration from a CT log to a Trillian tree.
func NewController ¶
func NewController( opts Options, ctClient *client.LogClient, plClient *PreorderedLogClient, ef election2.Factory, mf monitoring.MetricFactory, ) *Controller
NewController creates a Controller configured by the passed in options, CT and Trillian clients, and a master election factory.
The passed in MetricFactory is used to create per-tree metrics, and it should be the same for all instances. However, it is used only once.
func (*Controller) Run ¶
func (c *Controller) Run(ctx context.Context) error
Run transfers CT log entries obtained via the CT log client to a Trillian pre-ordered log via Trillian client. If Options.Continuous is true then the migration process runs continuously trying to keep up with the target CT log. Returns if an error occurs, the context is canceled, or all the entries have been transferred (in non-Continuous mode).
func (*Controller) RunWhenMaster ¶ added in v1.0.20
func (c *Controller) RunWhenMaster(ctx context.Context) error
RunWhenMaster is a master-elected version of Run method. It executes Run whenever this instance captures mastership of the tree ID. As soon as the instance stops being the master, Run is canceled. The method returns if a severe error occurs, the passed in context is canceled, or fetching is completed (in non-Continuous mode). Releases mastership when terminates.
func (*Controller) RunWhenMasterWithRestarts ¶ added in v1.1.0
func (c *Controller) RunWhenMasterWithRestarts(ctx context.Context)
RunWhenMasterWithRestarts calls RunWhenMaster, and, if the migration is configured with continuous mode, restarts it whenever it returns.
type Options ¶
type Options struct {
scanner.FetcherOptions
Submitters int
ChannelSize int
NoConsistencyCheck bool
StartDelay time.Duration
StopAfter time.Duration
}
Options holds configuration for a Controller.
func OptionsFromConfig ¶ added in v1.1.0
func OptionsFromConfig(cfg *configpb.MigrationConfig) Options
OptionsFromConfig returns Options created from the passed in config.
type PreorderedLogClient ¶
type PreorderedLogClient struct {
// contains filtered or unexported fields
}
PreorderedLogClient is a means of communicating with a single Trillian pre-ordered log tree.
func NewPreorderedLogClient ¶
func NewPreorderedLogClient( cli trillian.TrillianLogClient, tree *trillian.Tree, idFuncType configpb.IdentityFunction, prefix string, ) (*PreorderedLogClient, error)
NewPreorderedLogClient creates and initializes a pre-ordered log client.
Source Files