server

package

v0.5.0 Latest Latest Go to latest Published: Aug 8, 2025 License: MIT Imports: 9 Imported by: 0

Details

Package server provides a web server for real-time pgcopy state visualization

This section is empty.

This section is empty.

This section is empty.

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

WebServer provides a web interface for monitoring pgcopy operations

func NewWebServer(copyState *state.CopyState, port int) *WebServer

NewWebServer creates a new web server instance

func (ws *WebServer) OnStateChange(_ *state.CopyState, event state.Event)

OnStateChange implements the Listener interface

func (ws *WebServer) Shutdown(ctx context.Context) error

Shutdown gracefully stops the web server and unsubscribes from state updates

func (ws *WebServer) Start() error

Start starts the web server

func (ws *WebServer) WaitForCompletionAck(timeout time.Duration) bool

WaitForCompletionAck waits for the web client to acknowledge completion