grpccron

Documentation

Index

• type Engine
  • func NewCronEngine(lg Logger, cfg *EngineConfig) *Engine
  • func (e *Engine) Run() error
  • func (e *Engine) SetContext(ctx context.Context)
  • func (e *Engine) StartRepoActivity(repoId uuid.I, act grpcentities.RepoActivity) error
• type EngineConfig
• type Limiter
• type Logger

Types

type Engine

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

func NewCronEngine

func NewCronEngine(lg Logger, cfg *EngineConfig) *Engine

func (*Engine) Run

func (e *Engine) Run() error

func (*Engine) SetContext

func (e *Engine) SetContext(ctx context.Context)

func (*Engine) StartRepoActivity

func (e *Engine) StartRepoActivity(
	repoId uuid.I, act grpcentities.RepoActivity,
) error

type EngineConfig

type EngineConfig struct {
	Conn          *grpc.ClientConn
	SysRPCCreds   credentials.PerRPCCredentials
	StreamLimiter Limiter
	CronInterval  time.Duration
}

type Limiter

type Limiter interface {
	Acquire(ctx context.Context, n int64) error
	Release(n int64)
}

type Logger

type Logger interface {
	Infow(msg string, kv ...interface{})
	Warnw(msg string, kv ...interface{})
	Errorw(msg string, kv ...interface{})
}