cloudstorage

Documentation

Index

• type DDLSink
  • func NewDDLSink(ctx context.Context, changefeedID model.ChangeFeedID, sinkURI *url.URL, ...) (*DDLSink, error)
  • func (d *DDLSink) Close()
  • func (d *DDLSink) WriteCheckpointTs(ctx context.Context, ts uint64, tables []*model.TableInfo) error
  • func (d *DDLSink) WriteDDLEvent(ctx context.Context, ddl *model.DDLEvent) error

Types

type DDLSink

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

DDLSink is a sink that sends DDL events to the cloud storage system.

func NewDDLSink

func NewDDLSink(ctx context.Context,
	changefeedID model.ChangeFeedID,
	sinkURI *url.URL,
	replicaConfig *config.ReplicaConfig,
) (*DDLSink, error)

NewDDLSink creates a ddl sink for cloud storage.

func (*DDLSink) Close

func (d *DDLSink) Close()

Close closes the sink.

func (*DDLSink) WriteCheckpointTs

func (d *DDLSink) WriteCheckpointTs(ctx context.Context,
	ts uint64, tables []*model.TableInfo,
) error

WriteCheckpointTs writes the checkpoint ts to the cloud storage.

func (*DDLSink) WriteDDLEvent

func (d *DDLSink) WriteDDLEvent(ctx context.Context, ddl *model.DDLEvent) error

WriteDDLEvent writes the ddl event to the cloud storage.