Function NewRecordImpl

fs/contube/contube.go:119–124

(payload []byte, ackFunc func())

}

func NewRecordImpl(payload []byte, ackFunc func()) *RecordImpl {
	return &RecordImpl{
		payload:    payload,
		commitFunc: ackFunc,
	}
}

func NewSchemaRecordImpl(payload []byte, schema string, ackFunc func()) *RecordImpl {
	return &RecordImpl{