provider

type Consensus struct {
	// contains filtered or unexported fields
}

type DataItem struct {
	Key    []byte
	Value  []byte
	Expiry time.Time
}

type Options struct {
	// NodeID is the ID of the node.
	NodeID string
	// ListenPort is the port the storage API is listening on, if any.
	ListenPort int
	// MetricsPort is the address to bind the metrics endpoint to.
	MetricsPort int
	// ProbePort is the address to bind the health probe endpoint to.
	ProbePort int
	// ShutdownTimeout is the timeout for shutting down the provider.
	ShutdownTimeout time.Duration
	// Namespace is the namespace to use for leader election and storage.
	Namespace string
	// LeaderElectionLeaseDuration is the duration of the leader election lease.
	LeaderElectionLeaseDuration time.Duration
	// LeaderElectionRenewDeadline is the duration of the leader election lease renewal deadline.
	LeaderElectionRenewDeadline time.Duration
	// LeaderElectionRetryPeriod is the duration of the leader election lease retry period.
	LeaderElectionRetryPeriod time.Duration
	// DisableCache disables the cache.
	DisableCache bool
}

type Provider struct {
	Options
	// contains filtered or unexported fields
}

type Storage struct {
	*Provider
	// contains filtered or unexported fields
}

type Subscription struct {
	// contains filtered or unexported fields
}