api

type BackupConfiguration struct {
	BackupPeriodInHours          *int32  `json:"backupPeriodInHours"`
	BackupRetentionPeriodInHours *int32  `json:"backupRetentionPeriodInHours"`
	BackupStartTime              *string `json:"backupStartTime"`
}

type ClickPipe struct {
	ID            string                  `json:"id,omitempty"`
	Name          string                  `json:"name"`
	Description   string                  `json:"description"`
	Scaling       *ClickPipeScaling       `json:"scaling,omitempty"`
	State         string                  `json:"state,omitempty"`
	Source        ClickPipeSource         `json:"source"`
	Destination   ClickPipeDestination    `json:"destination"`
	FieldMappings []ClickPipeFieldMapping `json:"fieldMappings"`
	CreatedAt     *time.Time              `json:"createdAt,omitempty"`
	UpdatedAt     *time.Time              `json:"updatedAt,omitempty"`
}

type ClickPipeDestination struct {
	Database        string                               `json:"database"`
	Table           string                               `json:"table"`
	ManagedTable    bool                                 `json:"managedTable"`
	TableDefinition *ClickPipeDestinationTableDefinition `json:"tableDefinition,omitempty"`
	Columns         []ClickPipeDestinationColumn         `json:"columns"`
}

type ClickPipeDestinationColumn struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type ClickPipeDestinationTableDefinition struct {
	Engine      ClickPipeDestinationTableEngine `json:"engine"`
	SortingKey  []string                        `json:"sortingKey"`
	PartitionBy *string                         `json:"partitionBy,omitempty"`
	PrimaryKey  *string                         `json:"primaryKey,omitempty"`
}

type ClickPipeDestinationTableEngine struct {
	Type string `json:"type"`
}

type ClickPipeFieldMapping struct {
	SourceField      string `json:"sourceField"`
	DestinationField string `json:"destinationField"`
}

type ClickPipeKafkaOffset struct {
	Strategy  string  `json:"strategy"`
	Timestamp *string `json:"timestamp"`
}

type ClickPipeKafkaSchemaRegistry struct {
	URL            string                      `json:"url"`
	Authentication string                      `json:"authentication"`
	Credentials    *ClickPipeSourceCredentials `json:"credentials,omitempty"`
}

type ClickPipeKafkaSource struct {
	Type   string `json:"type"`
	Format string `json:"format"`

	Brokers string `json:"brokers"`
	Topics  string `json:"topics"`

	ConsumerGroup *string `json:"consumerGroup,omitempty"`

	Offset *ClickPipeKafkaOffset `json:"offset,omitempty"`

	SchemaRegistry *ClickPipeKafkaSchemaRegistry `json:"schemaRegistry,omitempty"`

	Authentication string                           `json:"authentication"`
	Credentials    *ClickPipeKafkaSourceCredentials `json:"credentials,omitempty"`
	IAMRole        *string                          `json:"iamRole,omitempty"`
	CACertificate  *string                          `json:"caCertificate,omitempty"`
}

type ClickPipeKafkaSourceCredentials struct {
	*ClickPipeSourceCredentials
	*ClickPipeSourceAccessKey

	ConnectionString *string `json:"connectionString,omitempty"`
}

type ClickPipeObjectStorageSource struct {
	Type   string `json:"type"`
	Format string `json:"format"`

	URL         string  `json:"url"`
	Delimiter   *string `json:"delimiter,omitempty"`
	Compression *string `json:"compression,omitempty"`

	IsContinuous bool `json:"isContinuous"`

	Authentication *string                   `json:"authentication,omitempty"`
	AccessKey      *ClickPipeSourceAccessKey `json:"accessKey,omitempty"`
	IAMRole        *string                   `json:"iamRole,omitempty"`
}

type ClickPipeScaling struct {
	Replicas *int64 `json:"replicas,omitempty"`
}

type ClickPipeScalingRequest struct {
	Replicas    *int64 `json:"replicas,omitempty"`
	Concurrency *int64 `json:"concurrency,omitempty"`
}

type ClickPipeSource struct {
	Kafka           *ClickPipeKafkaSource         `json:"kafka,omitempty"`
	ObjectStorage   *ClickPipeObjectStorageSource `json:"objectStorage,omitempty"`
	ValidateSamples bool                          `json:"validateSamples,omitempty"`
}

type ClickPipeSourceAccessKey struct {
	AccessKeyID string `json:"accessKeyId,omitempty"`
	SecretKey   string `json:"secretKey,omitempty"`
}

type ClickPipeSourceCredentials struct {
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

type ClickPipeStateRequest struct {
	Command string `json:"command"`
}

type Client interface {
	GetService(ctx context.Context, serviceId string) (*Service, error)
	GetOrgPrivateEndpointConfig(ctx context.Context, cloudProvider string, region string) (*OrgPrivateEndpointConfig, error)
	CreateService(ctx context.Context, s Service) (*Service, string, error)
	WaitForServiceState(ctx context.Context, serviceId string, stateChecker func(string) bool, maxWaitSeconds int) error
	UpdateService(ctx context.Context, serviceId string, s ServiceUpdate) (*Service, error)
	UpdateReplicaScaling(ctx context.Context, serviceId string, s ReplicaScalingUpdate) (*Service, error)
	UpdateServicePassword(ctx context.Context, serviceId string, u ServicePasswordUpdate) (*ServicePasswordUpdateResult, error)
	DeleteService(ctx context.Context, serviceId string) (*Service, error)
	GetOrganizationPrivateEndpoints(ctx context.Context) (*[]PrivateEndpoint, error)
	UpdateOrganizationPrivateEndpoints(ctx context.Context, orgUpdate OrganizationUpdate) (*[]PrivateEndpoint, error)
	GetBackupConfiguration(ctx context.Context, serviceId string) (*BackupConfiguration, error)
	UpdateBackupConfiguration(ctx context.Context, serviceId string, b BackupConfiguration) (*BackupConfiguration, error)
	GetClickPipe(ctx context.Context, serviceId string, clickPipeId string) (*ClickPipe, error)
	CreateClickPipe(ctx context.Context, serviceId string, clickPipe ClickPipe) (*ClickPipe, error)
	WaitForClickPipeState(ctx context.Context, serviceId string, clickPipeId string, stateChecker func(string) bool, maxWaitSeconds uint64) (*ClickPipe, error)
	ScalingClickPipe(ctx context.Context, serviceId string, clickPipeId string, request ClickPipeScaling) (*ClickPipe, error)
	ChangeClickPipeState(ctx context.Context, serviceId string, clickPipeId string, command string) (*ClickPipe, error)
	DeleteClickPipe(ctx context.Context, serviceId string, clickPipeId string) error
}

type ClientImpl struct {
	BaseUrl        string
	HttpClient     *http.Client
	OrganizationId string
	TokenKey       string
	TokenSecret    string
}

type ClientMock struct {
	ChangeClickPipeStateMock mClientMockChangeClickPipeState

	CreateClickPipeMock mClientMockCreateClickPipe

	CreateServiceMock mClientMockCreateService

	DeleteClickPipeMock mClientMockDeleteClickPipe

	DeleteServiceMock mClientMockDeleteService

	GetBackupConfigurationMock mClientMockGetBackupConfiguration

	GetClickPipeMock mClientMockGetClickPipe

	GetOrgPrivateEndpointConfigMock mClientMockGetOrgPrivateEndpointConfig

	GetOrganizationPrivateEndpointsMock mClientMockGetOrganizationPrivateEndpoints

	GetServiceMock mClientMockGetService

	ScalingClickPipeMock mClientMockScalingClickPipe

	UpdateBackupConfigurationMock mClientMockUpdateBackupConfiguration

	UpdateOrganizationPrivateEndpointsMock mClientMockUpdateOrganizationPrivateEndpoints

	UpdateReplicaScalingMock mClientMockUpdateReplicaScaling

	UpdateServiceMock mClientMockUpdateService

	UpdateServicePasswordMock mClientMockUpdateServicePassword

	WaitForClickPipeStateMock mClientMockWaitForClickPipeState

	WaitForServiceStateMock mClientMockWaitForServiceState
	// contains filtered or unexported fields
}

type ClientMockChangeClickPipeStateExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockCreateClickPipeExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockCreateServiceExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockDeleteClickPipeExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockDeleteServiceExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockGetBackupConfigurationExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockGetClickPipeExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockGetOrgPrivateEndpointConfigExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockGetOrganizationPrivateEndpointsExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockGetServiceExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockScalingClickPipeExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockUpdateBackupConfigurationExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockUpdateOrganizationPrivateEndpointsExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockUpdateReplicaScalingExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockUpdateServiceExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

type ClientMockUpdateServicePasswordExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

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

type ClientMockWaitForClickPipeStateExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type ClientMockWaitForServiceStateExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

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

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

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

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

type Endpoint struct {
	Protocol string `json:"protocol,omitempty"`
	Host     string `json:"host,omitempty"`
	Port     int    `json:"port,omitempty"`
}

type IpAccess struct {
	Source      string `json:"source,omitempty"`
	Description string `json:"description,omitempty"`
}

type IpAccessUpdate struct {
	Add    []IpAccess `json:"add,omitempty"`
	Remove []IpAccess `json:"remove,omitempty"`
}

type OrgPrivateEndpointConfig struct {
	EndpointServiceId string `json:"endpointServiceId,omitempty"`
}

type OrgPrivateEndpointsUpdate struct {
	Add    []PrivateEndpoint `json:"add,omitempty"`
	Remove []PrivateEndpoint `json:"remove,omitempty"`
}

type OrgResult struct {
	CreatedAt        string            `json:"createdAt,omitempty"`
	ID               string            `json:"id,omitempty"`
	Name             string            `json:"name,omitempty"`
	PrivateEndpoints []PrivateEndpoint `json:"privateEndpoints,omitempty"`
}

type OrganizationUpdate struct {
	PrivateEndpoints *OrgPrivateEndpointsUpdate `json:"privateEndpoints"`
}

type PrivateEndpoint struct {
	CloudProvider string `json:"cloudProvider,omitempty"`
	Description   string `json:"description,omitempty"`
	EndpointId    string `json:"id,omitempty"`
	Region        string `json:"region,omitempty"`
}

type PrivateEndpointIdsUpdate struct {
	Add    []string `json:"add,omitempty"`
	Remove []string `json:"remove,omitempty"`
}

type ReplicaScalingUpdate struct {
	IdleScaling        *bool `json:"idleScaling,omitempty"` // bool pointer so that `false“ is not omitted
	MinReplicaMemoryGb *int  `json:"minReplicaMemoryGb,omitempty"`
	MaxReplicaMemoryGb *int  `json:"maxReplicaMemoryGb,omitempty"`
	NumReplicas        *int  `json:"numReplicas,omitempty"`
	IdleTimeoutMinutes *int  `json:"idleTimeoutMinutes,omitempty"`
}

type ResponseWithResult[T any] struct {
	Result T `json:"result"`
}

type Service struct {
	Id                              string                        `json:"id,omitempty"`
	BYOCId                          *string                       `json:"byocId,omitempty"`
	Name                            string                        `json:"name"`
	Provider                        string                        `json:"provider"`
	Region                          string                        `json:"region"`
	Tier                            string                        `json:"tier"`
	IdleScaling                     bool                          `json:"idleScaling"`
	IpAccessList                    []IpAccess                    `json:"ipAccessList"`
	MinTotalMemoryGb                *int                          `json:"minTotalMemoryGb,omitempty"`
	MaxTotalMemoryGb                *int                          `json:"maxTotalMemoryGb,omitempty"`
	MinReplicaMemoryGb              *int                          `json:"minReplicaMemoryGb,omitempty"`
	MaxReplicaMemoryGb              *int                          `json:"maxReplicaMemoryGb,omitempty"`
	NumReplicas                     *int                          `json:"numReplicas,omitempty"`
	IdleTimeoutMinutes              *int                          `json:"idleTimeoutMinutes,omitempty"`
	State                           string                        `json:"state,omitempty"`
	Endpoints                       []Endpoint                    `json:"endpoints,omitempty"`
	IAMRole                         string                        `json:"iamRole,omitempty"`
	PrivateEndpointConfig           *ServicePrivateEndpointConfig `json:"privateEndpointConfig,omitempty"`
	PrivateEndpointIds              []string                      `json:"privateEndpointIds,omitempty"`
	EncryptionKey                   string                        `json:"encryptionKey,omitempty"`
	EncryptionAssumedRoleIdentifier string                        `json:"encryptionAssumedRoleIdentifier,omitempty"`
	BackupConfiguration             *BackupConfiguration          `json:"backupConfiguration,omitempty"`
	ReleaseChannel                  string                        `json:"releaseChannel,omitempty"`
}

type ServiceBody struct {
	Service Service `json:"service"`
}

type ServiceManagedEncryption struct {
	KeyArn        string `json:"keyArn,omitempty"`
	AssumeRoleArn string `json:"assumeRoleArn,omitempty"`
}

type ServicePasswordUpdate struct {
	NewPasswordHash   string `json:"newPasswordHash,omitempty"`
	NewDoubleSha1Hash string `json:"newDoubleSha1Hash,omitempty"`
}

type ServicePasswordUpdateResult struct {
	Password string `json:"password,omitempty"`
}

type ServicePrivateEndpointConfig struct {
	EndpointServiceId  string `json:"endpointServiceId,omitempty"`
	PrivateDnsHostname string `json:"privateDnsHostname,omitempty"`
}

type ServiceResponseResult struct {
	Service  Service `json:"service"`
	Password string  `json:"password"`
}

type ServiceStateUpdate struct {
	Command string `json:"command"`
}

type ServiceUpdate struct {
	Name               string                    `json:"name,omitempty"`
	IpAccessList       *IpAccessUpdate           `json:"ipAccessList,omitempty"`
	PrivateEndpointIds *PrivateEndpointIdsUpdate `json:"privateEndpointIds,omitempty"`
	ReleaseChannel     string                    `json:"releaseChannel,omitempty"`
}