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.