Documentation
¶
Index ¶
- type Datalog
- func (_m *Datalog) Init() error
- func (_m *Datalog) ReadFileFrom(buf []byte, maxSize int, segmentId int64, startOffset int64, maxRecords int, ...) ([]byte, error)
- func (_m *Datalog) ReadProducerOffset(topicId *types.TopicDataId) (int64, error)
- func (_m *Datalog) ReleaseStreamBuffer(buf []byte)
- func (_m *Datalog) SegmentFileList(topic *types.TopicDataId, maxOffset int64) ([]int64, error)
- func (_m *Datalog) StreamBuffer() []byte
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Datalog ¶
Datalog is an autogenerated mock type for the Datalog type
func NewDatalog ¶
func NewDatalog(t mockConstructorTestingTNewDatalog) *Datalog
NewDatalog creates a new instance of Datalog. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Datalog) ReadFileFrom ¶
func (_m *Datalog) ReadFileFrom(buf []byte, maxSize int, segmentId int64, startOffset int64, maxRecords int, topic *types.TopicDataId) ([]byte, error)
ReadFileFrom provides a mock function with given fields: buf, maxSize, segmentId, startOffset, maxRecords, topic
func (*Datalog) ReadProducerOffset ¶
func (_m *Datalog) ReadProducerOffset(topicId *types.TopicDataId) (int64, error)
ReadProducerOffset provides a mock function with given fields: topicId
func (*Datalog) ReleaseStreamBuffer ¶
ReleaseStreamBuffer provides a mock function with given fields: buf
func (*Datalog) SegmentFileList ¶
SegmentFileList provides a mock function with given fields: topic, maxOffset
func (*Datalog) StreamBuffer ¶
StreamBuffer provides a mock function with given fields:
Source Files
Click to show internal directories.
Click to hide internal directories.