metadata

package

v0.1.28 Latest Latest Go to latest Published: Jun 19, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sreekar2307/queue

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Bolt ¶

type Bolt struct {
	// contains filtered or unexported fields
}

func NewBolt ¶

func NewBolt(dbPath string) *Bolt

func (*Bolt) AddConsumerToGroupInTx ¶

func (b *Bolt) AddConsumerToGroupInTx(
	_ context.Context,
	tx storage.Transaction,
	group *model.ConsumerGroup,
	consumer *model.Consumer,
) error

func (*Bolt) AllConsumers ¶

func (b *Bolt) AllConsumers(_ context.Context) ([]*model.Consumer, error)

func (*Bolt) AllPartitions ¶

func (b *Bolt) AllPartitions(ctx context.Context) ([]*model.Partition, error)

func (*Bolt) AllPartitionsInTx ¶

func (b *Bolt) AllPartitionsInTx(_ context.Context, tx storage.Transaction) ([]*model.Partition, error)

func (*Bolt) AllTopics ¶

func (b *Bolt) AllTopics(ctx context.Context) ([]*model.Topic, error)

func (*Bolt) BeginTransaction ¶

func (b *Bolt) BeginTransaction(_ context.Context, forWrite bool) (storage.Transaction, error)

func (*Bolt) CheckCommandAppliedInTx ¶

func (b *Bolt) CheckCommandAppliedInTx(_ context.Context, tx storage.Transaction, commandID uint64) error

func (*Bolt) Close ¶

func (b *Bolt) Close(_ context.Context) error

func (*Bolt) Consumer ¶

func (b *Bolt) Consumer(ctx context.Context, s string) (*model.Consumer, error)

func (*Bolt) ConsumerGroup ¶

func (b *Bolt) ConsumerGroup(ctx context.Context, consumerGroupID string) (*model.ConsumerGroup, error)

func (*Bolt) ConsumerGroupInTx ¶

func (b *Bolt) ConsumerGroupInTx(
	_ context.Context,
	tx storage.Transaction,
	consumerGroupID string,
) (*model.ConsumerGroup, error)

func (*Bolt) ConsumerInTx ¶

func (b *Bolt) ConsumerInTx(_ context.Context, tx storage.Transaction, s string) (*model.Consumer, error)

func (*Bolt) CreateBrokerInTx ¶

func (b *Bolt) CreateBrokerInTx(
	_ context.Context,
	tx storage.Transaction,
	broker *model.Broker,
) error

func (*Bolt) CreateConsumerGroupInTx ¶

func (b *Bolt) CreateConsumerGroupInTx(
	_ context.Context,
	tx storage.Transaction,
	group *model.ConsumerGroup,
) error

func (*Bolt) CreateConsumerInTx ¶

func (b *Bolt) CreateConsumerInTx(_ context.Context, tx storage.Transaction, consumer *model.Consumer) error

func (*Bolt) CreatePartitionsInTx ¶

func (b *Bolt) CreatePartitionsInTx(
	_ context.Context,
	transaction storage.Transaction,
	partitions []*model.Partition,
) error

func (*Bolt) CreateTopicInTx ¶

func (b *Bolt) CreateTopicInTx(_ context.Context, tx storage.Transaction, topic *model.Topic) error

func (*Bolt) GetAllBrokers ¶ added in v0.1.7

func (b *Bolt) GetAllBrokers(ctx context.Context) ([]*model.Broker, error)

func (*Bolt) GetBroker ¶ added in v0.1.13

func (b *Bolt) GetBroker(
	_ context.Context,
	brokerID uint64,
) (*model.Broker, error)

func (*Bolt) GetBrokers ¶

func (b *Bolt) GetBrokers(_ context.Context, brokerIDs map[uint64]bool) ([]*model.Broker, error)

func (*Bolt) LastAppliedCommandID ¶

func (b *Bolt) LastAppliedCommandID(_ context.Context) (uint64, error)

func (*Bolt) Open ¶

func (b *Bolt) Open(_ context.Context) error

func (*Bolt) Partition ¶

func (b *Bolt) Partition(_ context.Context, s string) (*model.Partition, error)

func (*Bolt) PartitionAssignmentsInTx ¶

func (b *Bolt) PartitionAssignmentsInTx(
	_ context.Context,
	tx storage.Transaction,
	consumerGroupID string,
) (map[string][]string, error)

func (*Bolt) PartitionsForTopic ¶

func (b *Bolt) PartitionsForTopic(ctx context.Context, topicName string) ([]*model.Partition, error)

func (*Bolt) PartitionsForTopics ¶

func (b *Bolt) PartitionsForTopics(ctx context.Context, topicNames []string) ([]*model.Partition, error)

func (*Bolt) PartitionsInTx ¶

func (b *Bolt) PartitionsInTx(
	_ context.Context,
	tx storage.Transaction,
	topicNames map[string]bool,
) ([]*model.Partition, error)

func (*Bolt) RecoverFromSnapshot ¶

func (b *Bolt) RecoverFromSnapshot(_ context.Context, r io.Reader) error

func (*Bolt) RemoveConsumerFromGroupInTx ¶

func (b *Bolt) RemoveConsumerFromGroupInTx(
	_ context.Context,
	tx storage.Transaction,
	group *model.ConsumerGroup,
	consumer *model.Consumer,
) error

func (*Bolt) Snapshot ¶

func (b *Bolt) Snapshot(_ context.Context, w io.Writer) error

func (*Bolt) Topic ¶

func (b *Bolt) Topic(ctx context.Context, s string) (*model.Topic, error)

func (*Bolt) TopicInTx ¶

func (b *Bolt) TopicInTx(ctx context.Context, tx storage.Transaction, s string) (*model.Topic, error)

func (*Bolt) Topics ¶

func (b *Bolt) Topics(ctx context.Context, topicNames []string) ([]*model.Topic, error)

func (*Bolt) UpdateCommandAppliedInTx ¶

func (b *Bolt) UpdateCommandAppliedInTx(_ context.Context, tx storage.Transaction, commandID uint64) error

func (*Bolt) UpdateConsumer ¶

func (b *Bolt) UpdateConsumer(ctx context.Context, commandID uint64, consumer *model.Consumer) error

func (*Bolt) UpdateConsumerGroupInTx ¶

func (b *Bolt) UpdateConsumerGroupInTx(
	_ context.Context,
	tx storage.Transaction,
	group *model.ConsumerGroup,
) error

func (*Bolt) UpdateConsumerInTx ¶

func (b *Bolt) UpdateConsumerInTx(_ context.Context, tx storage.Transaction, consumer *model.Consumer) error

func (*Bolt) UpdatePartitionInTx ¶

func (b *Bolt) UpdatePartitionInTx(
	_ context.Context,
	tx storage.Transaction,
	partition *model.Partition,
) error

Source Files ¶

View all Source files

boltdb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL