synapse

Documentation

Index

• Constants
• Variables
• func CheckSynpaseMinRequirement(cpu float32, ram int64) bool
• func NewSynapseManager(ctx context.Context, logger lumber.Logger, redis core.RedisDB, ...) core.SynapseClientManager
• func NewSynapsePoolManager(ctx context.Context, logger lumber.Logger, redisDB core.RedisDB, ...) core.SynapsePoolManager
• type Specs
  • func GetResources(tierOpts core.Tier) Specs

Constants

const (
	PingInterval           = 5 * time.Second
	PongWait               = 10 * time.Second
	WsWait                 = 10 * time.Second
	DeRegisterWaitDuration = 10 * time.Minute
	MaxMessageSize         = 4096
)

Websocket connection options

const (
	TestExecutionMode = "testExecution"
	CoverageMode      = "coverageMode"
	BuildID           = "build-id"
	Repo              = "repo"
	Mode              = "mode"
	JobID             = "job-id"
	ID                = "id"
)

const related to task mode

const (
	Alive    = "Alive"
	NotAlive = "NotAlive"
)

constant related to synapse meta

Variables

var TierOpts = map[core.Tier]Specs{
	core.Internal: {CPU: 0.5, RAM: 384},
	core.XSmall:   {CPU: 1, RAM: 2000},
	core.Small:    {CPU: 2, RAM: 4000},
	core.Medium:   {CPU: 4, RAM: 8000},
	core.Large:    {CPU: 8, RAM: 16000},
	core.XLarge:   {CPU: 16, RAM: 32000},
}

TierOpts is const map which map each tier to specs

Functions

func CheckSynpaseMinRequirement

func CheckSynpaseMinRequirement(cpu float32, ram int64) bool

CheckSynpaseMinRequirement checks if synapse has enough resources

func NewSynapseManager

func NewSynapseManager(
	ctx context.Context,
	logger lumber.Logger,
	redis core.RedisDB,
	orgStore core.OrganizationStore,
	synapseStore core.SynapseStore,
	buildStore core.BuildStore,
	repoStore core.RepoStore,
	taskStore core.TaskStore,
	taskQueueUtils core.TaskQueueUtils,
	taskQueueManager core.TaskQueueManager) core.SynapseClientManager

NewSynapseManager returns new synapseManger

func NewSynapsePoolManager

func NewSynapsePoolManager(ctx context.Context,
	logger lumber.Logger,
	redisDB core.RedisDB,
	synapseStore core.SynapseStore,
	buildStore core.BuildStore,
	repoStore core.RepoStore,
	taskStore core.TaskStore,
	taskQueueUtils core.TaskQueueUtils,
	taskQueueManager core.TaskQueueManager,
	synapseManager core.SynapseClientManager) core.SynapsePoolManager

NewSynapsePoolManager returns new synapsePool

Types

type Specs

type Specs struct {
	CPU float32
	RAM int64
}

Specs denotes system specification

func GetResources

func GetResources(tierOpts core.Tier) Specs

GetResources function to get dummy resources based on pod type