server

Documentation

Index

• func New(pdEndpoints []string) (*server, error)
• func RecordGoRuntimeSettings()
• type Server

Functions

func New

func New(pdEndpoints []string) (*server, error)

New creates a server instance.

func RecordGoRuntimeSettings

func RecordGoRuntimeSettings()

RecordGoRuntimeSettings records GOGC settings.

Types

type Server

type Server interface {
	// Run runs the server.
	Run(ctx context.Context) error
	// Close closes the server.
	Close()
	// Drain removes tables in the current TiCDC instance.
	// It's part of graceful shutdown, should be called before Close.
	Drain() <-chan struct{}
}

Server is the interface for the TiCDC server