example

Documentation

Index

• type AlterPipeRequest
  • func NewAlterPipeRequest(name sdk.SchemaObjectIdentifier) *AlterPipeRequest
  • func (s *AlterPipeRequest) WithIfExists(ifExists bool) *AlterPipeRequest
  • func (s *AlterPipeRequest) WithRefresh(refresh PipeRefreshRequest) *AlterPipeRequest
  • func (s *AlterPipeRequest) WithSet(set PipeSetRequest) *AlterPipeRequest
  • func (s *AlterPipeRequest) WithSetTags(setTags PipeSetTagsRequest) *AlterPipeRequest
  • func (s *AlterPipeRequest) WithUnset(unset PipeUnsetRequest) *AlterPipeRequest
  • func (s *AlterPipeRequest) WithUnsetTags(unsetTags PipeUnsetTagsRequest) *AlterPipeRequest
• type CreatePipeRequest
  • func NewCreatePipeRequest(name sdk.SchemaObjectIdentifier, copyStatement string) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithAutoIngest(autoIngest bool) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithAwsSnsTopic(awsSnsTopic string) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithComment(comment string) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithErrorIntegration(errorIntegration string) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithExampleOfImport(exampleOfImport bytes.Buffer) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithIfNotExists(ifNotExists bool) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithIntegration(integration string) *CreatePipeRequest
  • func (s *CreatePipeRequest) WithOrReplace(orReplace bool) *CreatePipeRequest
• type PipeRefreshRequest
  • func NewPipeRefreshRequest() *PipeRefreshRequest
  • func (s *PipeRefreshRequest) WithModifiedAfter(modifiedAfter string) *PipeRefreshRequest
  • func (s *PipeRefreshRequest) WithPrefix(prefix string) *PipeRefreshRequest
• type PipeSetRequest
  • func NewPipeSetRequest() *PipeSetRequest
  • func (s *PipeSetRequest) WithComment(comment string) *PipeSetRequest
  • func (s *PipeSetRequest) WithErrorIntegration(errorIntegration string) *PipeSetRequest
  • func (s *PipeSetRequest) WithPipeExecutionPaused(pipeExecutionPaused bool) *PipeSetRequest
• type PipeSetTagsRequest
  • func NewPipeSetTagsRequest(tag []sdk.TagAssociation) *PipeSetTagsRequest
• type PipeUnsetRequest
  • func NewPipeUnsetRequest() *PipeUnsetRequest
  • func (s *PipeUnsetRequest) WithComment(comment bool) *PipeUnsetRequest
  • func (s *PipeUnsetRequest) WithPipeExecutionPaused(pipeExecutionPaused bool) *PipeUnsetRequest
• type PipeUnsetTagsRequest
  • func NewPipeUnsetTagsRequest(tag []sdk.ObjectIdentifier) *PipeUnsetTagsRequest

Types

type AlterPipeRequest

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

func NewAlterPipeRequest

func NewAlterPipeRequest(
	name sdk.SchemaObjectIdentifier,
) *AlterPipeRequest

func (*AlterPipeRequest) WithIfExists

func (s *AlterPipeRequest) WithIfExists(ifExists bool) *AlterPipeRequest

func (*AlterPipeRequest) WithRefresh

func (s *AlterPipeRequest) WithRefresh(refresh PipeRefreshRequest) *AlterPipeRequest

func (*AlterPipeRequest) WithSet

func (s *AlterPipeRequest) WithSet(set PipeSetRequest) *AlterPipeRequest

func (*AlterPipeRequest) WithSetTags

func (s *AlterPipeRequest) WithSetTags(setTags PipeSetTagsRequest) *AlterPipeRequest

func (*AlterPipeRequest) WithUnset

func (s *AlterPipeRequest) WithUnset(unset PipeUnsetRequest) *AlterPipeRequest

func (*AlterPipeRequest) WithUnsetTags

func (s *AlterPipeRequest) WithUnsetTags(unsetTags PipeUnsetTagsRequest) *AlterPipeRequest

type CreatePipeRequest

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

func NewCreatePipeRequest

func NewCreatePipeRequest(
	name sdk.SchemaObjectIdentifier,
	copyStatement string,
) *CreatePipeRequest

func (*CreatePipeRequest) WithAutoIngest

func (s *CreatePipeRequest) WithAutoIngest(autoIngest bool) *CreatePipeRequest

func (*CreatePipeRequest) WithAwsSnsTopic

func (s *CreatePipeRequest) WithAwsSnsTopic(awsSnsTopic string) *CreatePipeRequest

func (*CreatePipeRequest) WithComment

func (s *CreatePipeRequest) WithComment(comment string) *CreatePipeRequest

func (*CreatePipeRequest) WithErrorIntegration

func (s *CreatePipeRequest) WithErrorIntegration(errorIntegration string) *CreatePipeRequest

func (*CreatePipeRequest) WithExampleOfImport

func (s *CreatePipeRequest) WithExampleOfImport(exampleOfImport bytes.Buffer) *CreatePipeRequest

func (*CreatePipeRequest) WithIfNotExists

func (s *CreatePipeRequest) WithIfNotExists(ifNotExists bool) *CreatePipeRequest

func (*CreatePipeRequest) WithIntegration

func (s *CreatePipeRequest) WithIntegration(integration string) *CreatePipeRequest

func (*CreatePipeRequest) WithOrReplace

func (s *CreatePipeRequest) WithOrReplace(orReplace bool) *CreatePipeRequest

type PipeRefreshRequest

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

func NewPipeRefreshRequest

func NewPipeRefreshRequest() *PipeRefreshRequest

func (*PipeRefreshRequest) WithModifiedAfter

func (s *PipeRefreshRequest) WithModifiedAfter(modifiedAfter string) *PipeRefreshRequest

func (*PipeRefreshRequest) WithPrefix

func (s *PipeRefreshRequest) WithPrefix(prefix string) *PipeRefreshRequest

type PipeSetRequest

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

func NewPipeSetRequest

func NewPipeSetRequest() *PipeSetRequest

func (*PipeSetRequest) WithComment

func (s *PipeSetRequest) WithComment(comment string) *PipeSetRequest

func (*PipeSetRequest) WithErrorIntegration

func (s *PipeSetRequest) WithErrorIntegration(errorIntegration string) *PipeSetRequest

func (*PipeSetRequest) WithPipeExecutionPaused

func (s *PipeSetRequest) WithPipeExecutionPaused(pipeExecutionPaused bool) *PipeSetRequest

type PipeSetTagsRequest

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

func NewPipeSetTagsRequest

func NewPipeSetTagsRequest(
	tag []sdk.TagAssociation,
) *PipeSetTagsRequest

type PipeUnsetRequest

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

func NewPipeUnsetRequest

func NewPipeUnsetRequest() *PipeUnsetRequest

func (*PipeUnsetRequest) WithComment

func (s *PipeUnsetRequest) WithComment(comment bool) *PipeUnsetRequest

func (*PipeUnsetRequest) WithPipeExecutionPaused

func (s *PipeUnsetRequest) WithPipeExecutionPaused(pipeExecutionPaused bool) *PipeUnsetRequest

type PipeUnsetTagsRequest

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

func NewPipeUnsetTagsRequest

func NewPipeUnsetTagsRequest(
	tag []sdk.ObjectIdentifier,
) *PipeUnsetTagsRequest