repository

Documentation

Index

• type LogEventRepository
• type ProcessEventRepository
• type ProcessFootmarkRepository
• type ProcessLifeCycleEventRepository
• type ProcessRepository

Types

type LogEventRepository

type LogEventRepository interface {
	Store(log v1.LogEvent)
	GetByProcessId(processId string, option v1.LogEventQueryOption) ([]string, int64)
	GetByProcessIdAndStepAndFootmark(processId string, step string, footmark string, claim int, option v1.LogEventQueryOption) ([]string, int64)
	GetByProcessIdAndStepAndClaim(processId string, step string, claim int, option v1.LogEventQueryOption) ([]v1.LogEvent, int64)
}

LogEventRepository Log Event Repository operations.

type ProcessEventRepository

type ProcessEventRepository interface {
	Store(data v1.PipelineProcessEvent)
	GetByCompanyId(companyId string) map[string]interface{}
	GetByCompanyIdAndProcessId(companyId, processId string, option v1.ProcessQueryOption) ([]v1.PipelineProcessEvent, int64)
	DequeueByCompanyIdAndUserId(companyId, userId string) map[string]interface{}
}

ProcessEventRepository Process event repository operations.

type ProcessFootmarkRepository

type ProcessFootmarkRepository interface {
	Store(processFootmark v1.ProcessFootmark)
	GetByProcessId(processId string) []v1.ProcessFootmark
	GetByProcessIdAndStep(processId, step string) []v1.ProcessFootmark
	GetFootmarkByProcessIdAndStepAndFootmark(processId, step, footmark string) *v1.ProcessFootmark
}

ProcessFootmarkRepository Process log footmark Repository operations.

type ProcessLifeCycleEventRepository

type ProcessLifeCycleEventRepository interface {
	Store(data []v1.ProcessLifeCycleEvent)
	Get() []v1.ProcessLifeCycleEvent
	GetByProcessIdAndStep(processId, step string) v1.ProcessLifeCycleEvent
	GetByCompanyId(companyId string, fromDate, toDate time.Time) []v1.ProcessLifeCycleEvent
	PullPausedAndAutoTriggerEnabledResourcesByAgentName(count int64, agent string) []v1.ProcessLifeCycleEvent
	PullNonInitializedAndAutoTriggerEnabledEventsByStepType(count int64, stepType string) []v1.ProcessLifeCycleEvent
	GetByProcessId(processId string) []v1.ProcessLifeCycleEvent
	UpdateClaim(companyId, processId, step, status string) error
	UpdateStatusesByTime(time time.Time) error
	GetByTime(time time.Time) ([]v1.ProcessLifeCycleEvent, error)
}

ProcessLifeCycleEventRepository Process life cycle event repository operations.

type ProcessRepository

type ProcessRepository interface {
	Store(process v1.Process)
	GetById(companyId, processId string) v1.Process
	GetByCompanyIdAndRepositoryIdAndAppName(companyId, repositoryId, appId string, option v1.ProcessQueryOption) ([]v1.Process, int64)
	GetByCompanyIdAndCommitId(companyId, commitId string, option v1.ProcessQueryOption) ([]v1.Process, int64)
	CountTodaysRanProcessByCompanyId(companyId string) int64
	CountProcessByCompanyIdAndDate(companyId string, from, to time.Time) int64
}

ProcessRepository Process Repository operations.