grpclazy

package
v0.0.0-...-4450389 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 4, 2019 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const ConfigRetryRunTasksIntervalSeconds = 20
View Source
const ConfigRetryWatchSignalsWaitSeconds = 15
View Source
const NsFsoRegistry = "fsoreg"
View Source
const NsFsoRegistryEphemeralWorkflows = "fsoregephwfl"

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL