Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.
Documentation
¶
Index ¶
- type SourceHandler
- func (h *SourceHandler) CreateSource(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) DeleteSource(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) DiscoverDatabases(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) DiscoverReplication(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) DiscoverSourceColumns(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) DiscoverTables(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) GetSource(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) ListSources(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) ListWebhookRequests(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) ListWorkflowsReferencingSource(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) ProxyFetch(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) QuerySource(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) RegisterSourceRoutes(mux *http.ServeMux)
- func (h *SourceHandler) ReplayWebhookRequest(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) SampleSourceTable(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) TestSource(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) TriggerSnapshot(w http.ResponseWriter, r *http.Request)
- func (h *SourceHandler) UpdateSource(w http.ResponseWriter, r *http.Request)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SourceHandler ¶
func NewSourceHandler ¶
func NewSourceHandler(h *handlers.Handler) *SourceHandler
func (*SourceHandler) CreateSource ¶
func (h *SourceHandler) CreateSource(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) DeleteSource ¶
func (h *SourceHandler) DeleteSource(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) DiscoverDatabases ¶
func (h *SourceHandler) DiscoverDatabases(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) DiscoverReplication ¶
func (h *SourceHandler) DiscoverReplication(w http.ResponseWriter, r *http.Request)
DiscoverReplication returns the existing logical replication slots and publications for a CDC source so the user can reuse one or create a new one.
func (*SourceHandler) DiscoverSourceColumns ¶
func (h *SourceHandler) DiscoverSourceColumns(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) DiscoverTables ¶
func (h *SourceHandler) DiscoverTables(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) GetSource ¶
func (h *SourceHandler) GetSource(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) ListSources ¶
func (h *SourceHandler) ListSources(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) ListWebhookRequests ¶
func (h *SourceHandler) ListWebhookRequests(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) ListWorkflowsReferencingSource ¶
func (h *SourceHandler) ListWorkflowsReferencingSource(w http.ResponseWriter, r *http.Request)
listWorkflowsReferencingSource returns workflows that reference the given source ID.
func (*SourceHandler) ProxyFetch ¶
func (h *SourceHandler) ProxyFetch(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) QuerySource ¶
func (h *SourceHandler) QuerySource(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) RegisterSourceRoutes ¶
func (h *SourceHandler) RegisterSourceRoutes(mux *http.ServeMux)
func (*SourceHandler) ReplayWebhookRequest ¶
func (h *SourceHandler) ReplayWebhookRequest(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) SampleSourceTable ¶
func (h *SourceHandler) SampleSourceTable(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) TestSource ¶
func (h *SourceHandler) TestSource(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) TriggerSnapshot ¶
func (h *SourceHandler) TriggerSnapshot(w http.ResponseWriter, r *http.Request)
func (*SourceHandler) UpdateSource ¶
func (h *SourceHandler) UpdateSource(w http.ResponseWriter, r *http.Request)
Source Files
Click to show internal directories.
Click to hide internal directories.