store

Documentation

Overview

Ensign maintains two separate storage locations on disk: the event store which is intended to be an append-only fast disk write for incoming events and a meta store which is used to persist operational metadata such as topic and placement information.

Index

• func Open(conf config.StorageConfig) (data EventStore, meta MetaStore, err error)
• func OpenEvents(conf config.StorageConfig) (*events.Store, error)
• func OpenMeta(conf config.StorageConfig) (*meta.Store, error)
• type EventStore
• type GroupStore
• type MetaStore
• type Store
• type TopicNamesStore
• type TopicStore

Functions

func Open

func Open(conf config.StorageConfig) (data EventStore, meta MetaStore, err error)

func OpenEvents

func OpenEvents(conf config.StorageConfig) (*events.Store, error)

func OpenMeta

func OpenMeta(conf config.StorageConfig) (*meta.Store, error)

Types

type EventStore

type EventStore interface {
	Store
}

type GroupStore

type GroupStore interface {
	ListGroups(projectID ulid.ULID) iterator.GroupIterator
	GetOrCreateGroup(*api.ConsumerGroup) (bool, error)
	UpdateGroup(*api.ConsumerGroup) error
	DeleteGroup(*api.ConsumerGroup) error
}

type MetaStore

type MetaStore interface {
	Store
	TopicStore
	TopicNamesStore
}

type Store

type Store interface {
	io.Closer
	ReadOnly() bool
}

type TopicNamesStore

type TopicNamesStore interface {
	ListTopicNames(projectID ulid.ULID) iterator.TopicNamesIterator
	TopicExists(in *api.TopicName) (*api.TopicExistsInfo, error)
	TopicName(topicID ulid.ULID) (string, error)
}

type TopicStore

type TopicStore interface {
	AllowedTopics(projectID ulid.ULID) ([]ulid.ULID, error)
	ListTopics(projectID ulid.ULID) iterator.TopicIterator
	CreateTopic(*api.Topic) error
	RetrieveTopic(topicID ulid.ULID) (*api.Topic, error)
	UpdateTopic(*api.Topic) error
	DeleteTopic(topicID ulid.ULID) error
}