dtomaps

Documentation

Index

• func GetJobIdFromWorkflow(logger *slog.Logger, searchAttributes *commonpb.SearchAttributes) string
• func ToAccountApiKeyDto(input *db_queries.NeosyncApiAccountApiKey, cleartextKeyValue *string) *mgmtv1alpha1.AccountApiKey
• func ToAccountInviteDto(input *db_queries.NeosyncApiAccountInvite) *mgmtv1alpha1.AccountInvite
• func ToAccountTypeDto(aType int16) mgmtv1alpha1.UserAccountType
• func ToConnectionDto(input *db_queries.NeosyncApiConnection) (*mgmtv1alpha1.Connection, error)
• func ToJobDto(inputJob *db_queries.NeosyncApiJob, ...) *mgmtv1alpha1.Job
• func ToJobNextRunsDto(inputSchedule *temporalclient.ScheduleDescription) *mgmtv1alpha1.JobNextRuns
• func ToJobRecentRunsDto(inputSchedule *temporalclient.ScheduleDescription) []*mgmtv1alpha1.JobRecentRun
• func ToJobRunDto(logger *slog.Logger, input *workflowservice.DescribeWorkflowExecutionResponse) *mgmtv1alpha1.JobRun
• func ToJobRunDtoFromWorkflowExecutionInfo(workflow *workflowpb.WorkflowExecutionInfo, logger *slog.Logger) *mgmtv1alpha1.JobRun
• func ToJobRunEventTaskDto(event *history.HistoryEvent, taskError *mgmtv1alpha1.JobRunEventTaskError) *mgmtv1alpha1.JobRunEventTask
• func ToJobRunEventTaskErrorDto(failure *temporalfailure.Failure, retryState enums.RetryState) *mgmtv1alpha1.JobRunEventTaskError
• func ToJobStatus(inputSchedule *temporalclient.ScheduleDescription) mgmtv1alpha1.JobStatus
• func ToUserAccount(input *db_queries.NeosyncApiAccount) *mgmtv1alpha1.UserAccount
• func ToUserDefinedTransformerDto(input *db_queries.NeosyncApiTransformer, ...) (*mgmtv1alpha1.UserDefinedTransformer, error)

Functions

func GetJobIdFromWorkflow

func GetJobIdFromWorkflow(logger *slog.Logger, searchAttributes *commonpb.SearchAttributes) string

func ToAccountApiKeyDto

func ToAccountApiKeyDto(
	input *db_queries.NeosyncApiAccountApiKey,
	cleartextKeyValue *string,
) *mgmtv1alpha1.AccountApiKey

func ToAccountInviteDto

func ToAccountInviteDto(input *db_queries.NeosyncApiAccountInvite) *mgmtv1alpha1.AccountInvite

func ToAccountTypeDto

func ToAccountTypeDto(aType int16) mgmtv1alpha1.UserAccountType

func ToConnectionDto

func ToConnectionDto(
	input *db_queries.NeosyncApiConnection,
) (*mgmtv1alpha1.Connection, error)

func ToJobDto

func ToJobDto(
	inputJob *db_queries.NeosyncApiJob,
	inputDestConnections []db_queries.NeosyncApiJobDestinationConnectionAssociation,
) *mgmtv1alpha1.Job

func ToJobNextRunsDto

func ToJobNextRunsDto(inputSchedule *temporalclient.ScheduleDescription) *mgmtv1alpha1.JobNextRuns

func ToJobRecentRunsDto

func ToJobRecentRunsDto(inputSchedule *temporalclient.ScheduleDescription) []*mgmtv1alpha1.JobRecentRun

func ToJobRunDto

func ToJobRunDto(
	logger *slog.Logger,
	input *workflowservice.DescribeWorkflowExecutionResponse,
) *mgmtv1alpha1.JobRun

including pending activities

func ToJobRunDtoFromWorkflowExecutionInfo

func ToJobRunDtoFromWorkflowExecutionInfo(workflow *workflowpb.WorkflowExecutionInfo, logger *slog.Logger) *mgmtv1alpha1.JobRun

returns a job run without any pending activities

func ToJobRunEventTaskDto

func ToJobRunEventTaskDto(event *history.HistoryEvent, taskError *mgmtv1alpha1.JobRunEventTaskError) *mgmtv1alpha1.JobRunEventTask

func ToJobRunEventTaskErrorDto

func ToJobRunEventTaskErrorDto(failure *temporalfailure.Failure, retryState enums.RetryState) *mgmtv1alpha1.JobRunEventTaskError

func ToJobStatus

func ToJobStatus(inputSchedule *temporalclient.ScheduleDescription) mgmtv1alpha1.JobStatus

func ToUserAccount

func ToUserAccount(input *db_queries.NeosyncApiAccount) *mgmtv1alpha1.UserAccount

func ToUserDefinedTransformerDto

func ToUserDefinedTransformerDto(
	input *db_queries.NeosyncApiTransformer,
	systemTransformers map[mgmtv1alpha1.TransformerSource]*mgmtv1alpha1.SystemTransformer,
) (*mgmtv1alpha1.UserDefinedTransformer, error)