Documentation ¶
Index ¶
- func Put(ctx context.Context, bs *BlockStore)
- type Allocator
- type BlockStore
- func (s *BlockStore) Append(ctx context.Context, block uint64, events *cloudevents.CloudEventBatch) ([]int64, error)
- func (s *BlockStore) Close()
- func (s *BlockStore) Describe(ctx context.Context, block uint64) (*metapb.SegmentHealthInfo, error)
- func (s *BlockStore) Endpoint() string
- func (s *BlockStore) LookupOffset(ctx context.Context, blockID uint64, t time.Time) (int64, error)
- func (s *BlockStore) Read(ctx context.Context, block uint64, offset int64, size int16, ...) (*cloudevents.CloudEventBatch, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Allocator ¶
type Allocator struct {
// contains filtered or unexported fields
}
func NewAllocator ¶
func NewAllocator() *Allocator
type BlockStore ¶
func Get ¶
func Get(ctx context.Context, endpoint string) (*BlockStore, error)
Get acquire BlockStore.
func (*BlockStore) Append ¶
func (s *BlockStore) Append(ctx context.Context, block uint64, events *cloudevents.CloudEventBatch) ([]int64, error)
func (*BlockStore) Close ¶
func (s *BlockStore) Close()
func (*BlockStore) Describe ¶
func (s *BlockStore) Describe(ctx context.Context, block uint64) (*metapb.SegmentHealthInfo, error)
func (*BlockStore) Endpoint ¶
func (s *BlockStore) Endpoint() string
func (*BlockStore) LookupOffset ¶
func (*BlockStore) Read ¶
func (s *BlockStore) Read( ctx context.Context, block uint64, offset int64, size int16, pollingTimeout uint32, ) (*cloudevents.CloudEventBatch, error)
Click to show internal directories.
Click to hide internal directories.