Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

wide

package

Go to main page

Versions in this module

v1

v1.0.0

Nov 12, 2020

Changes in this version

+ type EntryChecksumMismatchChecker interface

+ ComputeMismatchesForEntry func(entry xio.IndexChecksum) ([]ReadMismatch, error)

+ Drain func() []ReadMismatch

+ Lock func()

+ Unlock func()

+ func NewEntryChecksumMismatchChecker(blockReader IndexChecksumBlockBatchReader, opts Options) EntryChecksumMismatchChecker

+ type IndexChecksumBlockBatch struct

+ Checksums []int64

+ EndMarker []byte

+ type IndexChecksumBlockBatchReader interface

+ Close func()

+ Current func() IndexChecksumBlockBatch

+ Next func() bool

+ func NewIndexChecksumBlockBatchReader(blockInput chan IndexChecksumBlockBatch) IndexChecksumBlockBatchReader

+ type MockEntryChecksumMismatchChecker struct

+ func NewMockEntryChecksumMismatchChecker(ctrl *gomock.Controller) *MockEntryChecksumMismatchChecker

+ func (m *MockEntryChecksumMismatchChecker) ComputeMismatchesForEntry(arg0 xio.IndexChecksum) ([]ReadMismatch, error)

+ func (m *MockEntryChecksumMismatchChecker) Drain() []ReadMismatch

+ func (m *MockEntryChecksumMismatchChecker) EXPECT() *MockEntryChecksumMismatchCheckerMockRecorder

+ func (m *MockEntryChecksumMismatchChecker) Lock()

+ func (m *MockEntryChecksumMismatchChecker) Unlock()

+ type MockEntryChecksumMismatchCheckerMockRecorder struct

+ func (mr *MockEntryChecksumMismatchCheckerMockRecorder) ComputeMismatchesForEntry(arg0 interface{}) *gomock.Call

+ func (mr *MockEntryChecksumMismatchCheckerMockRecorder) Drain() *gomock.Call

+ func (mr *MockEntryChecksumMismatchCheckerMockRecorder) Lock() *gomock.Call

+ func (mr *MockEntryChecksumMismatchCheckerMockRecorder) Unlock() *gomock.Call

+ type MockStreamedMismatch struct

+ func NewMockStreamedMismatch(ctrl *gomock.Controller) *MockStreamedMismatch

+ func (m *MockStreamedMismatch) EXPECT() *MockStreamedMismatchMockRecorder

+ func (m *MockStreamedMismatch) RetrieveMismatch() (ReadMismatch, error)

+ type MockStreamedMismatchMockRecorder struct

+ func (mr *MockStreamedMismatchMockRecorder) RetrieveMismatch() *gomock.Call

+ type Options interface

+ BatchSize func() int

+ DecodingOptions func() msgpack.DecodingOptions

+ InstrumentOptions func() instrument.Options

+ SetBatchSize func(value int) Options

+ SetDecodingOptions func(value msgpack.DecodingOptions) Options

+ SetInstrumentOptions func(value instrument.Options) Options

+ Validate func() error

+ func NewOptions() Options

+ type ReadMismatch struct

+ Data checked.Bytes

+ func (r ReadMismatch) IsReaderMismatch() bool

+ type StreamedMismatch interface

+ RetrieveMismatch func() (ReadMismatch, error)

+ var EmptyStreamedMismatch StreamedMismatch = emptyStreamedMismatch{}

v1.0.0-rc.3

Nov 12, 2020

v1.0.0-rc.2

Nov 12, 2020

v1.0.0-rc.1

Nov 10, 2020

v1.0.0-rc.0

Nov 9, 2020