cmd

package
v0.0.0-...-bd61e48 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2026 License: AGPL-3.0 Imports: 67 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ErrorInfoReasonClickHousePeer = "CLICKHOUSE_PEER"
	ErrorInfoReasonMirror         = "MIRROR"
)
View Source 
const (
	ErrorMetadataDownstreamErrorCode = "downstreamErrorCode"
	ErrorMetadataOffendingField      = "offendingField"
)
View Source 
const (
	ErrorInfoDomain = "peerdb.io"
)

Variables

View Source 
var CustomColumnTypeRegex = regexp.MustCompile(`^$|^[a-zA-Z][a-zA-Z0-9(),]*$`)
View Source 
var ErrUnderMaintenance = errors.New("PeerDB is under maintenance. Please retry in a few minutes")

Functions

func APIMain 

func APIMain(ctx context.Context, args *APIServerParams) error

func CheckK8sServiceExistence 

func CheckK8sServiceExistence(ctx context.Context, serviceName string) (bool, error)

func MaintenanceMain 

func MaintenanceMain(ctx context.Context, args *MaintenanceCLIParams) error

MaintenanceMain is the entry point for the maintenance command, requires access to Temporal client, will exit after running the requested maintenance workflow

func NewAlreadyExistsApiError 

func NewAlreadyExistsApiError(err error, details ...*rpc.ErrorInfo) *apiError

func NewClickHousePeerErrorInfo 

func NewClickHousePeerErrorInfo(metadata map[string]string) *rpc.ErrorInfo

func NewFailedPreconditionApiError 

func NewFailedPreconditionApiError(err error, details ...*rpc.ErrorInfo) *apiError

func NewInternalApiError 

func NewInternalApiError(err error, details ...*rpc.ErrorInfo) *apiError

func NewInvalidArgumentApiError 

func NewInvalidArgumentApiError(err error, details ...*rpc.ErrorInfo) *apiError

func NewMirrorErrorInfo 

func NewMirrorErrorInfo(metadata map[string]string) *rpc.ErrorInfo

func NewNotFoundApiError 

func NewNotFoundApiError(err error, details ...*rpc.ErrorInfo) *apiError

func NewUnavailableApiError 

func NewUnavailableApiError(err error, details ...*rpc.ErrorInfo) *apiError

func NewUnimplementedApiError 

func NewUnimplementedApiError(err error, details ...*rpc.ErrorInfo) *apiError

func WriteMaintenanceOutputToCatalog 

func WriteMaintenanceOutputToCatalog(ctx context.Context, result StartMaintenanceResult) error

Types

type APIError 

type APIError = grpc_handler.APIError

APIError is a strongly-typed error that must be a gRPC status error. All handler methods should return this type instead of the generic error interface.

func AsAPIError 

func AsAPIError(err error) APIError

AsAPIError converts an error to APIError if it's a gRPC status error, otherwise wraps it as an Internal error

type APIServerParams 

type APIServerParams struct {
	TemporalHostPort  string
	TemporalNamespace string
	Port              uint16
	GatewayPort       uint16
	EnableOtelMetrics bool
}

type FlowRequestHandler 

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

grpc server implementation

func NewFlowRequestHandler 

func NewFlowRequestHandler(ctx context.Context, temporalClient client.Client, pool shared.CatalogPool, taskQueue string) *FlowRequestHandler

func (*FlowRequestHandler) CDCBatches 

func (h *FlowRequestHandler) CDCBatches(ctx context.Context, req *protos.GetCDCBatchesRequest) (*protos.GetCDCBatchesResponse, APIError)

func (*FlowRequestHandler) CDCGraph 

func (h *FlowRequestHandler) CDCGraph(ctx context.Context, req *protos.GraphRequest) (*protos.GraphResponse, APIError)

func (*FlowRequestHandler) CDCTableTotalCounts 

func (h *FlowRequestHandler) CDCTableTotalCounts(
	ctx context.Context,
	req *protos.CDCTableTotalCountsRequest,
) (*protos.CDCTableTotalCountsResponse, APIError)

func (*FlowRequestHandler) CancelTableAddition 

func (h *FlowRequestHandler) CancelTableAddition(
	ctx context.Context,
	req *protos.CancelTableAdditionInput,
) (*protos.CancelTableAdditionOutput, APIError)

func (*FlowRequestHandler) CreateCDCFlow 

func (h *FlowRequestHandler) CreateCDCFlow(
	ctx context.Context, req *protos.CreateCDCFlowRequest,
) (*protos.CreateCDCFlowResponse, APIError)

func (*FlowRequestHandler) CreateOrReplaceFlowTags 

func (h *FlowRequestHandler) CreateOrReplaceFlowTags(
	ctx context.Context,
	in *protos.CreateOrReplaceFlowTagsRequest,
) (*protos.CreateOrReplaceFlowTagsResponse, APIError)

func (*FlowRequestHandler) CreatePeer 

func (h *FlowRequestHandler) CreatePeer(
	ctx context.Context,
	req *protos.CreatePeerRequest,
) (*protos.CreatePeerResponse, APIError)

func (*FlowRequestHandler) CreateQRepFlow 

func (h *FlowRequestHandler) CreateQRepFlow(
	ctx context.Context, req *protos.CreateQRepFlowRequest,
) (*protos.CreateQRepFlowResponse, APIError)

func (*FlowRequestHandler) DeleteAlertConfig 

func (h *FlowRequestHandler) DeleteAlertConfig(
	ctx context.Context,
	req *protos.DeleteAlertConfigRequest,
) (*protos.DeleteAlertConfigResponse, APIError)

func (*FlowRequestHandler) DeleteScript 

func (h *FlowRequestHandler) DeleteScript(
	ctx context.Context,
	req *protos.DeleteScriptRequest,
) (*protos.DeleteScriptResponse, APIError)

func (*FlowRequestHandler) DropPeer 

func (h *FlowRequestHandler) DropPeer(
	ctx context.Context,
	req *protos.DropPeerRequest,
) (*protos.DropPeerResponse, APIError)

func (*FlowRequestHandler) FlowStateChange 

func (h *FlowRequestHandler) FlowStateChange(
	ctx context.Context,
	req *protos.FlowStateChangeRequest,
) (*protos.FlowStateChangeResponse, APIError)

func (*FlowRequestHandler) GetAlertConfigs 

func (h *FlowRequestHandler) GetAlertConfigs(
	ctx context.Context,
	req *protos.GetAlertConfigsRequest,
) (*protos.GetAlertConfigsResponse, APIError)

func (*FlowRequestHandler) GetAllTables 

func (h *FlowRequestHandler) GetAllTables(
	ctx context.Context,
	req *protos.PostgresPeerActivityInfoRequest,
) (*protos.AllTablesResponse, APIError)

Returns list of tables across schema in schema.table format

func (*FlowRequestHandler) GetCDCBatches 

func (h *FlowRequestHandler) GetCDCBatches(ctx context.Context, req *protos.GetCDCBatchesRequest) (*protos.GetCDCBatchesResponse, APIError)

func (*FlowRequestHandler) GetColumns 

func (h *FlowRequestHandler) GetColumns(
	ctx context.Context,
	req *protos.TableColumnsRequest,
) (*protos.TableColumnsResponse, APIError)

func (*FlowRequestHandler) GetColumnsTypeConversion 

func (h *FlowRequestHandler) GetColumnsTypeConversion(
	ctx context.Context,
	req *protos.ColumnsTypeConversionRequest,
) (*protos.ColumnsTypeConversionResponse, APIError)

func (*FlowRequestHandler) GetDynamicSettings 

func (h *FlowRequestHandler) GetDynamicSettings(
	ctx context.Context,
	req *protos.GetDynamicSettingsRequest,
) (*protos.GetDynamicSettingsResponse, APIError)

func (*FlowRequestHandler) GetFlowTags 

func (h *FlowRequestHandler) GetFlowTags(ctx context.Context, in *protos.GetFlowTagsRequest) (*protos.GetFlowTagsResponse, APIError)

func (*FlowRequestHandler) GetInstanceInfo 

func (h *FlowRequestHandler) GetInstanceInfo(ctx context.Context, in *protos.InstanceInfoRequest) (*protos.InstanceInfoResponse, APIError)

func (*FlowRequestHandler) GetMaintenanceStatus 

func (h *FlowRequestHandler) GetMaintenanceStatus(
	ctx context.Context,
	in *protos.MaintenanceStatusRequest,
) (*protos.MaintenanceStatusResponse, APIError)

func (*FlowRequestHandler) GetPeerInfo 

func (h *FlowRequestHandler) GetPeerInfo(
	ctx context.Context,
	req *protos.PeerInfoRequest,
) (*protos.PeerInfoResponse, APIError)

func (*FlowRequestHandler) GetPeerType 

func (h *FlowRequestHandler) GetPeerType(
	ctx context.Context,
	req *protos.PeerInfoRequest,
) (*protos.PeerTypeResponse, APIError)

func (*FlowRequestHandler) GetPublications 

func (h *FlowRequestHandler) GetPublications(
	ctx context.Context,
	req *protos.PostgresPeerActivityInfoRequest,
) (*protos.PeerPublicationsResponse, APIError)

func (*FlowRequestHandler) GetSchemas 

func (h *FlowRequestHandler) GetSchemas(
	ctx context.Context,
	req *protos.PostgresPeerActivityInfoRequest,
) (*protos.PeerSchemasResponse, APIError)

func (*FlowRequestHandler) GetScripts 

func (h *FlowRequestHandler) GetScripts(ctx context.Context, req *protos.GetScriptsRequest) (*protos.GetScriptsResponse, APIError)

func (*FlowRequestHandler) GetSlotInfo 

func (h *FlowRequestHandler) GetSlotInfo(
	ctx context.Context,
	req *protos.PostgresPeerActivityInfoRequest,
) (*protos.PeerSlotResponse, APIError)

func (*FlowRequestHandler) GetSlotLagHistory 

func (h *FlowRequestHandler) GetSlotLagHistory(
	ctx context.Context,
	req *protos.GetSlotLagHistoryRequest,
) (*protos.GetSlotLagHistoryResponse, APIError)

func (*FlowRequestHandler) GetStatInfo 

func (h *FlowRequestHandler) GetStatInfo(
	ctx context.Context,
	req *protos.PostgresPeerActivityInfoRequest,
) (*protos.PeerStatResponse, APIError)

func (*FlowRequestHandler) GetTablesInSchema 

func (h *FlowRequestHandler) GetTablesInSchema(
	ctx context.Context,
	req *protos.SchemaTablesRequest,
) (*protos.SchemaTablesResponse, APIError)

func (*FlowRequestHandler) GetVersion 

func (h *FlowRequestHandler) GetVersion(
	ctx context.Context,
	req *protos.PeerDBVersionRequest,
) (*protos.PeerDBVersionResponse, APIError)

func (*FlowRequestHandler) InitialLoadSummary 

func (h *FlowRequestHandler) InitialLoadSummary(
	ctx context.Context,
	req *protos.InitialLoadSummaryRequest,
) (*protos.InitialLoadSummaryResponse, APIError)

func (*FlowRequestHandler) ListMirrorLogs 

func (h *FlowRequestHandler) ListMirrorLogs(
	ctx context.Context,
	req *protos.ListMirrorLogsRequest,
) (*protos.ListMirrorLogsResponse, APIError)

func (*FlowRequestHandler) ListMirrorNames 

func (h *FlowRequestHandler) ListMirrorNames(
	ctx context.Context,
	req *protos.ListMirrorNamesRequest,
) (*protos.ListMirrorNamesResponse, APIError)

func (*FlowRequestHandler) ListMirrors 

func (h *FlowRequestHandler) ListMirrors(
	ctx context.Context,
	req *protos.ListMirrorsRequest,
) (*protos.ListMirrorsResponse, APIError)

func (*FlowRequestHandler) ListPeers 

func (h *FlowRequestHandler) ListPeers(
	ctx context.Context,
	req *protos.ListPeersRequest,
) (*protos.ListPeersResponse, APIError)

func (*FlowRequestHandler) Maintenance 

func (h *FlowRequestHandler) Maintenance(ctx context.Context, in *protos.MaintenanceRequest) (*protos.MaintenanceResponse, APIError)

func (*FlowRequestHandler) MirrorStatus 

func (h *FlowRequestHandler) MirrorStatus(
	ctx context.Context,
	req *protos.MirrorStatusRequest,
) (*protos.MirrorStatusResponse, APIError)

func (*FlowRequestHandler) PostAlertConfig 

func (h *FlowRequestHandler) PostAlertConfig(
	ctx context.Context,
	req *protos.PostAlertConfigRequest,
) (*protos.PostAlertConfigResponse, APIError)

func (*FlowRequestHandler) PostDynamicSetting 

func (h *FlowRequestHandler) PostDynamicSetting(
	ctx context.Context,
	req *protos.PostDynamicSettingRequest,
) (*protos.PostDynamicSettingResponse, APIError)

func (*FlowRequestHandler) PostScript 

func (h *FlowRequestHandler) PostScript(ctx context.Context, req *protos.PostScriptRequest) (*protos.PostScriptResponse, APIError)

func (*FlowRequestHandler) SkipSnapshotWaitFlows 

func (h *FlowRequestHandler) SkipSnapshotWaitFlows(
	ctx context.Context,
	in *protos.SkipSnapshotWaitFlowsRequest,
) (*protos.SkipSnapshotWaitFlowsResponse, APIError)

SkipSnapshotWaitFlows sends a signal to skip snapshot wait for the specified flows if StartMaintenanceWorkflow is running

func (*FlowRequestHandler) TotalRowsSyncedByMirror 

func (h *FlowRequestHandler) TotalRowsSyncedByMirror(
	ctx context.Context,
	req *protos.TotalRowsSyncedByMirrorRequest,
) (*protos.TotalRowsSyncedByMirrorResponse, APIError)

func (*FlowRequestHandler) ValidateCDCMirror 

func (h *FlowRequestHandler) ValidateCDCMirror(
	ctx context.Context, req *protos.CreateCDCFlowRequest,
) (*protos.ValidateCDCMirrorResponse, APIError)

func (*FlowRequestHandler) ValidatePeer 

func (h *FlowRequestHandler) ValidatePeer(
	ctx context.Context,
	req *protos.ValidatePeerRequest,
) (*protos.ValidatePeerResponse, APIError)

type LoggedActivityInboundInterceptor 

type LoggedActivityInboundInterceptor struct {
	interceptor.ActivityInboundInterceptorBase
	Next interceptor.ActivityInboundInterceptor
}

func NewLoggedActivityInboundInterceptor 

func NewLoggedActivityInboundInterceptor(next interceptor.ActivityInboundInterceptor) *LoggedActivityInboundInterceptor

func (*LoggedActivityInboundInterceptor) ExecuteActivity 

func (c *LoggedActivityInboundInterceptor) ExecuteActivity(
	ctx context.Context,
	in *interceptor.ExecuteActivityInput,
) (any, error)

type LoggedWorkerInterceptor 

type LoggedWorkerInterceptor struct {
	interceptor.WorkerInterceptorBase
}

func NewLoggedWorkerInterceptor 

func NewLoggedWorkerInterceptor() *LoggedWorkerInterceptor

func (LoggedWorkerInterceptor) InterceptActivity 

func (c LoggedWorkerInterceptor) InterceptActivity(
	ctx context.Context,
	next interceptor.ActivityInboundInterceptor,
) interceptor.ActivityInboundInterceptor

func (LoggedWorkerInterceptor) InterceptWorkflow 

func (c LoggedWorkerInterceptor) InterceptWorkflow(
	ctx workflow.Context,
	next interceptor.WorkflowInboundInterceptor,
) interceptor.WorkflowInboundInterceptor

type LoggedWorkflowInboundInterceptor 

type LoggedWorkflowInboundInterceptor struct {
	interceptor.WorkflowInboundInterceptorBase
	Next interceptor.WorkflowInboundInterceptor
}

func NewLoggedWorkflowInboundInterceptor 

func NewLoggedWorkflowInboundInterceptor(next interceptor.WorkflowInboundInterceptor) *LoggedWorkflowInboundInterceptor

func (*LoggedWorkflowInboundInterceptor) ExecuteWorkflow 

func (w *LoggedWorkflowInboundInterceptor) ExecuteWorkflow(
	ctx workflow.Context,
	in *interceptor.ExecuteWorkflowInput,
) (any, error)

type MaintenanceCLIParams 

type MaintenanceCLIParams struct {
	TemporalHostPort                  string
	TemporalNamespace                 string
	Mode                              string
	FlowGrpcAddress                   string
	SkipIfK8sServiceMissing           string
	FlowTlsEnabled                    bool
	SkipOnApiVersionMatch             bool
	SkipOnDeploymentVersionMatch      bool
	SkipOnNoMirrors                   bool
	UseMaintenanceTaskQueue           bool
	AssumeSkippedMaintenanceWorkflows bool
}

type RecryptItem 

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

type SnapshotWorkerOptions 

type SnapshotWorkerOptions struct {
	TemporalHostPort  string
	TemporalNamespace string
	EnableOtelMetrics bool
}

type StartMaintenanceResult 

type StartMaintenanceResult struct {
	SkippedReason    *string `json:"skippedReason,omitempty"`
	APIVersion       string  `json:"apiVersion,omitempty"`
	CLIVersion       string  `json:"cliVersion,omitempty"`
	APIDeployVersion string  `json:"apiDeployVersion,omitempty"`
	CLIDeployVersion string  `json:"cliDeployVersion,omitempty"`
	Skipped          bool    `json:"skipped,omitempty"`
}

func ReadLastMaintenanceOutput 

func ReadLastMaintenanceOutput(ctx context.Context) (*StartMaintenanceResult, error)

type WorkerSetupOptions 

type WorkerSetupOptions struct {
	TemporalHostPort                   string
	TemporalNamespace                  string
	TemporalMaxConcurrentActivities    int
	TemporalMaxConcurrentWorkflowTasks int
	EnableOtelMetrics                  bool
	UseMaintenanceTaskQueue            bool
}

type WorkerSetupResponse 

type WorkerSetupResponse struct {
	Client      client.Client
	Worker      worker.Worker
	OtelManager *otel_metrics.OtelManager
}

func SnapshotWorkerMain 

func SnapshotWorkerMain(ctx context.Context, opts *SnapshotWorkerOptions) (*WorkerSetupResponse, error)

func WorkerSetup 

func WorkerSetup(ctx context.Context, opts *WorkerSetupOptions) (*WorkerSetupResponse, error)

func (*WorkerSetupResponse) Close 

func (w *WorkerSetupResponse) Close(ctx context.Context)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.