clickhouse

package

Go to main page

Versions in this module

v0

v0.11.2

Mar 7, 2025

v0.11.1

Mar 5, 2025

Changes in this version

type TestCase

+ JobId int64

type TestReport

+ JobId int64

type TestSuite

+ JobId int64

v0.11.0

Feb 23, 2025

Changes in this version

+ const DeploymentsTable

+ func InsertDeployments(c *Client, ctx context.Context, deployments []*typespb.Deployment) (int, error)

+ type Deployment struct

+ CreatedAt float64

+ EnvironmentId int64

+ EnvironmentName string

+ EnvironmentTier string

+ FinishedAt float64

+ Id int64

+ Iid int64

+ JobId int64

+ PipelineId int64

+ ProjectId int64

+ Ref string

+ Sha string

+ Status string

+ TriggererId int64

+ TriggererName string

+ TriggererUsername string

+ UpdatedAt float64

v0.10.1

Feb 16, 2025

Changes in this version

type MergeRequest

+ ApproversName []string

+ ApproversUsername []string

+ AssigneesName []string

+ AssigneesUsername []string

+ AuthorName string

+ AuthorUsername string

+ MergeUserName string

+ MergeUserUsername string

+ ReviewersName []string

+ ReviewersUsername []string

type MergeRequestNoteEvent

+ AuthorName string

+ AuthorUsername string

+ ResolverName string

+ ResolverUsername string

v0.10.0

Feb 4, 2025

Changes in this version

+ func MigrateDown(opts MigrationOptions) error

+ type Job struct

+ AllowFailure bool

+ Coverage float64

+ CreatedAt float64

+ DownstreamPipelineId int64

+ DownstreamPipelineIid int64

+ DownstreamPipelineProjectId int64

+ Duration float64

+ ErasedAt float64

+ FailureReason string

+ FinishedAt float64

+ Id int64

+ Kind string

+ Manual bool

+ Name string

+ Pipeline []any

+ PipelineId int64

+ ProjectId int64

+ QueuedAt float64

+ QueuedDuration float64

+ Ref string

+ Retried bool

+ Retryable bool

+ RunnerId string

+ Stage string

+ StartedAt float64

+ Status string

+ TagList []string

+ type MergeRequest struct

+ Additions int64

+ Approved bool

+ ApproversId []int64

+ AssigneesId []int64

+ AuthorId int64

+ BaseSha string

+ Changes int64

+ ClosedAt float64

+ CommitCount int64

+ Conflicts bool

+ CreatedAt float64

+ Deletions int64

+ Draft bool

+ FileCount int64

+ HeadSha string

+ Id int64

+ Iid int64

+ Labels []string

+ MergeCommitSha string

+ MergeError string

+ MergeStatus string

+ MergeUserId int64

+ Mergeable bool

+ MergedAt float64

+ MilestoneId int64

+ MilestoneIid int64

+ MilestoneProjectId int64

+ Name string

+ ProjectId int64

+ RebaseCommitSha string

+ ReviewersId []int64

+ SourceBranch string

+ SourceProjectId int64

+ StartSha string

+ State string

+ TargetBranch string

+ TargetProjectId int64

+ Title string

+ UpdatedAt float64

+ type MergeRequestNoteEvent struct

+ AuthorId int64

+ CreatedAt float64

+ Id int64

+ Internal bool

+ MergeRequestId int64

+ MergeRequestIid int64

+ MergeRequestProjectId int64

+ Resolvable bool

+ Resolved bool

+ ResolvedAt float64

+ ResolverId int64

+ System bool

+ Type string

+ UpdatedAt float64

+ type Metric struct

+ Id string

+ Iid int64

+ JobId int64

+ Labels map[string]string

+ Name string

+ PipelineId int64

+ ProjectId int64

+ Timestamp int64

+ Value float64

+ type Pipeline struct

+ Child bool

+ CommittedAt float64

+ Coverage float64

+ CreatedAt float64

+ Duration float64

+ FailureReason string

+ FinishedAt float64

+ Id int64

+ Iid int64

+ MergeRequestId int64

+ MergeRequestIid int64

+ MergeRequestProjectId int64

+ Name string

+ ProjectId int64

+ QueuedDuration float64

+ Ref string

+ Sha string

+ Source string

+ StartedAt float64

+ Status string

+ UpdatedAt float64

+ UpstreamPipelineId int64

+ UpstreamPipelineIid int64

+ UpstreamPipelineProjectId int64

+ UserId int64

+ Warnings bool

+ YamlErrors bool

+ type Project struct

+ Archived bool

+ CommitCount int64

+ ContainerRegistrySize int64

+ CreatedAt float64

+ Description string

+ ForksCount int64

+ FullName string

+ FullPath string

+ Id int64

+ JobArtifactsSize int64

+ LastActivityAt float64

+ LfsObjectsSize int64

+ Name string

+ NamespaceId int64

+ OpenIssuesCount int64

+ PackagesSize int64

+ Path string

+ PipelineArtifactsSize int64

+ RepositorySize int64

+ SnippetsSize int64

+ StarsCount int64

+ StorageSize int64

+ Topics []string

+ UpdatedAt float64

+ UploadsSize int64

+ Visibility string

+ WikiSize int64

+ type Section struct

+ Duration float64

+ FinishedAt float64

+ Id int64

+ Job []any

+ JobId int64

+ Name string

+ Pipeline []any

+ PipelineId int64

+ ProjectId int64

+ StartedAt float64

+ type TestCase struct

+ AttachmentUrl string

+ Classname string

+ ExecutionTime float64

+ File string

+ Id string

+ Name string

+ PipelineId int64

+ ProjectId int64

+ Properties [][]string

+ Status string

+ SystemOutput string

+ TestReportId string

+ TestSuiteId string

+ type TestReport struct

+ ErrorCount int64

+ FailedCount int64

+ Id string

+ PipelineId int64

+ ProjectId int64

+ SkippedCount int64

+ SuccessCount int64

+ TotalCount int64

+ TotalTime float64

+ type TestSuite struct

+ ErrorCount int64

+ FailedCount int64

+ Id string

+ Name string

+ PipelineId int64

+ ProjectId int64

+ Properties [][]string

+ SkippedCount int64

+ SuccessCount int64

+ TestReportId string

+ TotalCount int64

+ TotalTime float64

v0.9.0

Jan 21, 2025

Changes in this version

type Client

+ func (c *Client) SetMaxConcurrentQueries(n int64)

v0.8.3

Nov 1, 2024

v0.8.2

Oct 30, 2024

v0.8.1

Oct 30, 2024

v0.8.0

Oct 2, 2024

Changes in this version

+ const MergeRequestNoteEventsTable

+ func InsertMergeRequestNoteEvents(c *Client, ctx context.Context, mres []*typespb.MergeRequestNoteEvent) (int, error)

v0.7.1

Jul 19, 2024

v0.7.0

Jul 18, 2024

Changes in this version

+ const MergeRequestsTable

+ const MetricsTable

+ const ProjectsTable

+ var ErrMigrateNilVersion = migrate.ErrNilVersion

+ var ErrMigrateNoChange = migrate.ErrNoChange

+ func GetLatestMigrationVersion(fsys fs.FS, path string) (uint, error)

+ func GetSchemaVersion(c *Client, ctx context.Context) (uint, bool, error)

+ func InsertMergeRequests(c *Client, ctx context.Context, mrs []*typespb.MergeRequest) (int, error)

+ func InsertProjects(c *Client, ctx context.Context, projects []*typespb.Project) (int, error)

+ func MigrateUp(opts MigrationOptions) error

+ func NewMigration(opts MigrationOptions) (*migrate.Migrate, error)

+ func SelectTableIDLastestUpdates(c *Client, ctx context.Context, table string, idColumn string, ...) (map[int64]float64, error)

type Cache

+ func (c *Cache) UpdateMergeRequests(data map[int64]float64, updated map[int64]bool)

+ func (c *Cache) UpdateMetrics(keys map[int64]bool)

+ func (c *Cache) UpdateProjects(data map[int64]float64, updated map[int64]bool)

+ type MigrationOptions struct

+ FileSystem fs.FS

+ Path string

v0.6.2

Mar 4, 2024

v0.6.1

Feb 26, 2024

Changes in this version

+ func ClientOptions(cfg ClientConfig) clickhouse.Options

+ func Connect(options *clickhouse.Options) (driver.Conn, error)

v0.6.0

Feb 25, 2024

v0.5.3

Feb 23, 2024

v0.5.2

Feb 23, 2024

v0.5.1

Feb 22, 2024

v0.5.0

Feb 22, 2024

Changes in this version

+ const BridgesTable

+ const JobsTable

+ const LogEmbeddedMetricsTable

+ const PipelinesTable

+ const SectionsTable

+ const TestCasesTable

+ const TestReportsTable

+ const TestSuitesTable

+ const TraceSpansTable

+ func DeduplicateTable(ctx context.Context, opt DeduplicateTableOptions, ch *Client) error

+ func InsertBridges(c *Client, ctx context.Context, bridges []*typespb.Bridge) (int, error)

+ func InsertJobs(c *Client, ctx context.Context, jobs []*typespb.Job) (int, error)

+ func InsertMetrics(c *Client, ctx context.Context, metrics []*typespb.Metric) (int, error)

+ func InsertPipelines(c *Client, ctx context.Context, pipelines []*typespb.Pipeline) (int, error)

+ func InsertSections(c *Client, ctx context.Context, sections []*typespb.Section) (int, error)

+ func InsertTestCases(c *Client, ctx context.Context, cases []*typespb.TestCase) (int, error)

+ func InsertTestReports(c *Client, ctx context.Context, reports []*typespb.TestReport) (int, error)

+ func InsertTestSuites(c *Client, ctx context.Context, suites []*typespb.TestSuite) (int, error)

+ func InsertTraces(c *Client, ctx context.Context, traces []*typespb.Trace) (int, error)

+ func PrepareDeduplicateQuery(opt DeduplicateTableOptions) (string, map[string]string)

+ func SelectPipelineMaxUpdatedAt(c *Client, ctx context.Context) (map[int64]float64, error)

+ func SelectTableIDs[T int64 | string](c *Client, ctx context.Context, table string, column string) (map[T]struct{}, error)

+ func SelectTraceSpanIDs(c *Client, ctx context.Context) (map[string]struct{}, error)

+ func WithParameters(ctx context.Context, params map[string]string) context.Context

+ type Cache struct

+ func NewCache() *Cache

+ func (c *Cache) UpdateBridges(data []int64) []bool

+ func (c *Cache) UpdateJobs(data []int64) []bool

+ func (c *Cache) UpdateLogEmbeddedMetrics(data []int64) []bool

+ func (c *Cache) UpdatePipelines(data map[int64]float64) map[int64]bool

+ func (c *Cache) UpdateSections(data []int64) []bool

+ func (c *Cache) UpdateTestCases(data []string) []bool

+ func (c *Cache) UpdateTestReports(data []string) []bool

+ func (c *Cache) UpdateTestSuites(data []string) []bool

+ func (c *Cache) UpdateTraceSpans(data []string) []bool

+ type Client struct

+ func NewClient(cfg ClientConfig) (*Client, error)

+ func (c *Client) Configure(cfg ClientConfig) error

+ func (c *Client) CreateTables(ctx context.Context) error

+ func (c *Client) Exec(ctx context.Context, query string, args ...any) error

+ func (c *Client) InitCache(ctx context.Context) error

+ func (c *Client) Ping(ctx context.Context) error

+ func (c *Client) PrepareBatch(ctx context.Context, query string) (driver.Batch, error)

+ func (c *Client) Select(ctx context.Context, dest any, query string, args ...any) error

+ type ClientConfig struct

+ Database string

+ Host string

+ Password string

+ Port string

+ User string

+ type DeduplicateTableOptions struct

+ By []string

+ Database string

+ Except []string

+ Final *bool

+ Table string

+ ThrowIfNoop *bool

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