bucket

Documentation

Index

• func NewBucketIDProvider(numberOfBuckets uint32) (*bucketIDProvider, error)
• func NewBucketIndexHandler(bucket core.Storer) (*bucketIndexHandler, error)
• func NewMongoDBIndexHandler(mongoClient mongodb.MongoDBClient, collID mongodb.CollectionID) (*mongodbIndexHandler, error)
• func NewShardedStorageWithIndex(args ArgShardedStorageWithIndex) (*shardedStorageWithIndex, error)
• type ArgShardedStorageWithIndex

Functions

func NewBucketIDProvider

func NewBucketIDProvider(numberOfBuckets uint32) (*bucketIDProvider, error)

NewBucketIDProvider returns a new instance of bucket id provider

func NewBucketIndexHandler

func NewBucketIndexHandler(bucket core.Storer) (*bucketIndexHandler, error)

NewBucketIndexHandler returns a new instance of a bucket index handler

func NewMongoDBIndexHandler

func NewMongoDBIndexHandler(mongoClient mongodb.MongoDBClient, collID mongodb.CollectionID) (*mongodbIndexHandler, error)

NewMongoDBIndexHandler returns a new instance of a mongodb index handler

func NewShardedStorageWithIndex

func NewShardedStorageWithIndex(args ArgShardedStorageWithIndex) (*shardedStorageWithIndex, error)

NewShardedStorageWithIndex returns a new instance of sharded storage with index

Types

type ArgShardedStorageWithIndex

type ArgShardedStorageWithIndex struct {
	BucketIDProvider core.BucketIDProvider
	BucketHandlers   map[uint32]core.IndexHandler
}

ArgShardedStorageWithIndex is the DTO used to create a new instance of sharded storage with index