Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var NewCDCRecord = pool.NewCDCRecord
NewCDCRecord creates a new record for Change Data Capture
View Source
var NewRecord = pool.NewRecord
NewRecord creates a new record with the given source and data
View Source
var NewRecordFromPool = pool.NewRecordFromPool
NewRecordFromPool creates a new record using pooled resources
View Source
var NewStreamingRecord = pool.NewStreamingRecord
NewStreamingRecord creates a new record for streaming
Functions ¶
This section is empty.
Types ¶
type Field ¶
type Field struct {
// Name of the field
Name string `json:"name"`
// Type of the field (string, integer, float, boolean, object, array)
Type string `json:"type"`
// Description of the field (optional)
Description string `json:"description,omitempty"`
// Required indicates if the field is required
Required bool `json:"required"`
// Fields for nested objects
Fields []Field `json:"fields,omitempty"`
}
Field represents a single field in the schema
type IRecord ¶
type IRecord interface {
ToModelsRecord() *Record
Release()
}
IRecord interface for backward compatibility
type RecordBatch ¶
type RecordBatch struct {
Records []*Record
// contains filtered or unexported fields
}
RecordBatch represents a batch of records
func NewRecordBatch ¶
func NewRecordBatch(capacity int) *RecordBatch
NewRecordBatch creates a new record batch
func (*RecordBatch) AddRecord ¶
func (rb *RecordBatch) AddRecord(r *Record)
AddRecord adds a record to the batch
func (*RecordBatch) Size ¶
func (rb *RecordBatch) Size() int
Size returns the number of records in the batch
type RecordMetadata ¶
type RecordMetadata = pool.RecordMetadata
type RecordWrapper ¶
type RecordWrapper struct {
// contains filtered or unexported fields
}
RecordWrapper implements IRecord for backward compatibility
func (*RecordWrapper) Release ¶
func (w *RecordWrapper) Release()
Release releases the record back to the pool
func (*RecordWrapper) ToModelsRecord ¶
func (w *RecordWrapper) ToModelsRecord() *Record
ToModelsRecord returns the underlying Record
Click to show internal directories.
Click to hide internal directories.