Documentation
¶
Index ¶
- type PeerClickHouse
- func (p *PeerClickHouse) Connect(config json.RawMessage, args ...any) error
- func (p *PeerClickHouse) Disconnect() error
- func (p *PeerClickHouse) Pub(event cdc.Event, args ...any) error
- func (p *PeerClickHouse) Sub(args ...any) (<-chan cdc.Event, error)
- func (p *PeerClickHouse) Type() pipeline.ConnectorType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PeerClickHouse ¶
type PeerClickHouse struct {
// contains filtered or unexported fields
}
func (*PeerClickHouse) Connect ¶
func (p *PeerClickHouse) Connect(config json.RawMessage, args ...any) error
func (*PeerClickHouse) Disconnect ¶
func (p *PeerClickHouse) Disconnect() error
func (*PeerClickHouse) Type ¶
func (p *PeerClickHouse) Type() pipeline.ConnectorType
Source Files
Click to show internal directories.
Click to hide internal directories.