generated

Documentation

Index

• Constants
• Variables
• func RegisterCDCStreamServer(s grpc.ServiceRegistrar, srv CDCStreamServer)
• type CDCEvent
  • func (*CDCEvent) Descriptor() ([]byte, []int)
  • func (x *CDCEvent) GetData() []byte
  • func (x *CDCEvent) GetTable() string
  • func (*CDCEvent) ProtoMessage()
  • func (x *CDCEvent) ProtoReflect() protoreflect.Message
  • func (x *CDCEvent) Reset()
  • func (x *CDCEvent) String() string
• type CDCStreamClient
  • func NewCDCStreamClient(cc grpc.ClientConnInterface) CDCStreamClient
• type CDCStreamServer
• type CDCStream_StreamClient
• type CDCStream_StreamServer
• type StreamRequest
  • func (*StreamRequest) Descriptor() ([]byte, []int)
  • func (*StreamRequest) ProtoMessage()
  • func (x *StreamRequest) ProtoReflect() protoreflect.Message
  • func (x *StreamRequest) Reset()
  • func (x *StreamRequest) String() string
• type UnimplementedCDCStreamServer
  • func (UnimplementedCDCStreamServer) Stream(*StreamRequest, grpc.ServerStreamingServer[CDCEvent]) error
• type UnsafeCDCStreamServer

Constants

const (
	CDCStream_Stream_FullMethodName = "/grpc.CDCStream/Stream"
)

Variables

var CDCStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc.CDCStream",
	HandlerType: (*CDCStreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _CDCStream_Stream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cdc.proto",
}

CDCStream_ServiceDesc is the grpc.ServiceDesc for CDCStream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_cdc_proto protoreflect.FileDescriptor

Functions

func RegisterCDCStreamServer

func RegisterCDCStreamServer(s grpc.ServiceRegistrar, srv CDCStreamServer)

Types

type CDCEvent

type CDCEvent struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` // schema_name.table_name
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`   // JSON encoded event.Payload.After data
	// contains filtered or unexported fields
}

func (*CDCEvent) Descriptor

func (*CDCEvent) Descriptor() ([]byte, []int)

Deprecated: Use CDCEvent.ProtoReflect.Descriptor instead.

func (*CDCEvent) GetData

func (x *CDCEvent) GetData() []byte

func (*CDCEvent) GetTable

func (x *CDCEvent) GetTable() string

func (*CDCEvent) ProtoMessage

func (*CDCEvent) ProtoMessage()

func (*CDCEvent) ProtoReflect

func (x *CDCEvent) ProtoReflect() protoreflect.Message

func (*CDCEvent) Reset

func (x *CDCEvent) Reset()

func (*CDCEvent) String

func (x *CDCEvent) String() string

type CDCStreamClient

type CDCStreamClient interface {
	Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CDCEvent], error)
}

CDCStreamClient is the client API for CDCStream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCDCStreamClient

func NewCDCStreamClient(cc grpc.ClientConnInterface) CDCStreamClient

type CDCStreamServer

type CDCStreamServer interface {
	Stream(*StreamRequest, grpc.ServerStreamingServer[CDCEvent]) error
	// contains filtered or unexported methods
}

CDCStreamServer is the server API for CDCStream service. All implementations must embed UnimplementedCDCStreamServer for forward compatibility.

type CDCStream_StreamClient

type CDCStream_StreamClient = grpc.ServerStreamingClient[CDCEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CDCStream_StreamServer

type CDCStream_StreamServer = grpc.ServerStreamingServer[CDCEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StreamRequest

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

func (*StreamRequest) Descriptor

func (*StreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) ProtoMessage

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect

func (x *StreamRequest) ProtoReflect() protoreflect.Message

func (*StreamRequest) Reset

func (x *StreamRequest) Reset()

func (*StreamRequest) String

func (x *StreamRequest) String() string

type UnimplementedCDCStreamServer

type UnimplementedCDCStreamServer struct{}

UnimplementedCDCStreamServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCDCStreamServer) Stream

func (UnimplementedCDCStreamServer) Stream(*StreamRequest, grpc.ServerStreamingServer[CDCEvent]) error

type UnsafeCDCStreamServer

type UnsafeCDCStreamServer interface {
	// contains filtered or unexported methods
}

UnsafeCDCStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CDCStreamServer will result in compilation errors.