grpc

package

v0.0.1 Latest Latest Go to latest Published: May 24, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type PeerGRPC struct {
	pipeline.Peer
	// contains filtered or unexported fields
}

PeerGRPC implements both source and sink functionality for gRPC

func (p *PeerGRPC) Connect(config json.RawMessage, args ...any) error

func (p *PeerGRPC) Disconnect() error

func (p *PeerGRPC) Pub(event cdc.Event, args ...any) error

func (p *PeerGRPC) Sub(args ...any) (<-chan cdc.Event, error)

func (p *PeerGRPC) Type() pipeline.ConnectorType