syncrepo

Documentation

Index

• type Config
  • func (cfg *Config) Validate() error
• type SyncRepo
  • func NewSyncRepo(cfg *Config, service app.SyncService) *SyncRepo
  • func (d *SyncRepo) Run(ctx context.Context, cfg *Config, log *logrus.Entry) error

Types

type Config

type Config struct {
	Topic     string `json:"topic"                 required:"true"`
	UserAgent string `json:"user_agent"            required:"true"`

	// The unit is Gbyte
	SizeOfWorspace int `json:"size_of_workspace"   required:"true"`

	// The unit is Gbyte
	AverageRepoSize int `json:"average_repo_size"  required:"true"`

	// kfk
	Kafka kfklib.Config `json:"kafka"`
}

func (*Config) Validate

func (cfg *Config) Validate() error

type SyncRepo

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

func NewSyncRepo

func NewSyncRepo(cfg *Config, service app.SyncService) *SyncRepo

func (*SyncRepo) Run

func (d *SyncRepo) Run(ctx context.Context, cfg *Config, log *logrus.Entry) error