dlq

Documentation

Index

• type LocalServer
• type Recovery
  • func NewRecovery(logger log.Logger, config RecoveryConfig, metastore LocalServer, ...) *Recovery
  • func (r *Recovery) Start()
  • func (r *Recovery) Stop()
• type RecoveryConfig
  • func (c *RecoveryConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

Types

type LocalServer

type LocalServer interface {
	AddRecoveredBlock(context.Context, *metastorev1.AddBlockRequest) (*metastorev1.AddBlockResponse, error)
}

type Recovery

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

func NewRecovery

func NewRecovery(logger log.Logger, config RecoveryConfig, metastore LocalServer, bucket objstore.Bucket) *Recovery

func (*Recovery) Start

func (r *Recovery) Start()

func (*Recovery) Stop

func (r *Recovery) Stop()

type RecoveryConfig

type RecoveryConfig struct {
	Period time.Duration `yaml:"dlq_recovery_check_interval"`
}

func (*RecoveryConfig) RegisterFlagsWithPrefix

func (c *RecoveryConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)