grpclazy

Documentation

Index

• Constants
• type Engine
  • func NewEngine(lg Logger, cfg *EngineConfig) *Engine
  • func (e *Engine) Run() error
  • func (e *Engine) SetContext(ctx context.Context)
  • func (e *Engine) StartRegistryActivity(registry string, act grpcentities.RegistryActivity) error
  • func (e *Engine) StartRegistryWorkflowActivity(registry string, workflowId uuid.I, act grpcentities.RegistryWorkflowActivity) error
  • func (e *Engine) StartRegistryWorkflowIndexActivity(registry string, act grpcentities.RegistryWorkflowIndexActivity) error
  • func (e *Engine) StartRepoActivity(repoId uuid.I, act grpcentities.RepoActivity) error
  • func (e *Engine) StartRepoWorkflowActivity(repoId uuid.I, workflowId uuid.I, act grpcentities.RepoWorkflowActivity) error
• type EngineConfig
• type Limiter
• type Logger

Constants

const ConfigRetryRunTasksIntervalSeconds = 20

const ConfigRetryWatchSignalsWaitSeconds = 15

const NsFsoRegistry = "fsoreg"

const NsFsoRegistryEphemeralWorkflows = "fsoregephwfl"

Types

type Engine

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

func NewEngine

func NewEngine(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) StartRegistryActivity

func (e *Engine) StartRegistryActivity(
	registry string, act grpcentities.RegistryActivity,
) error

func (*Engine) StartRegistryWorkflowActivity

func (e *Engine) StartRegistryWorkflowActivity(
	registry string,
	workflowId uuid.I,
	act grpcentities.RegistryWorkflowActivity,
) error

func (*Engine) StartRegistryWorkflowIndexActivity

func (e *Engine) StartRegistryWorkflowIndexActivity(
	registry string, act grpcentities.RegistryWorkflowIndexActivity,
) error

func (*Engine) StartRepoActivity

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

func (*Engine) StartRepoWorkflowActivity

func (e *Engine) StartRepoWorkflowActivity(
	repoId uuid.I,
	workflowId uuid.I,
	act grpcentities.RepoWorkflowActivity,
) error

type EngineConfig

type EngineConfig struct {
	Conn                       *grpc.ClientConn
	SysRPCCreds                credentials.PerRPCCredentials
	StreamLimiter              Limiter
	StreamLimiterRegistry      Limiter
	StreamLimiterRepos         Limiter
	StreamLimiterRepoWorkflows Limiter
}

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{})
}