mock

Documentation

Index

• Constants
• func UnmarshalTopicList(data []byte, jsonpb *protojson.UnmarshalOptions) (topics []*api.Topic, err error)
• type Store
  • func Open(conf config.StorageConfig) (*Store, error)
  • func (s *Store) AllowedTopics(projectID ulid.ULID) ([]ulid.ULID, error)
  • func (s *Store) Calls(call string) int
  • func (s *Store) Close() error
  • func (s *Store) CreateTopic(topic *api.Topic) error
  • func (s *Store) DeleteTopic(topicID ulid.ULID) error
  • func (s *Store) ListTopicNames(projectID ulid.ULID) iterator.TopicNamesIterator
  • func (s *Store) ListTopics(projectID ulid.ULID) iterator.TopicIterator
  • func (s *Store) ReadOnly() bool
  • func (s *Store) Reset()
  • func (s *Store) RetrieveTopic(topicID ulid.ULID) (*api.Topic, error)
  • func (s *Store) TopicExists(in *api.TopicName) (*api.TopicExistsInfo, error)
  • func (s *Store) TopicName(topicID ulid.ULID) (string, error)
  • func (s *Store) UpdateTopic(topic *api.Topic) error
  • func (s *Store) UseError(call string, err error) error
  • func (s *Store) UseFixture(call, path string) (err error)
• type TopicIterator
  • func NewErrorIterator(err error) *TopicIterator
  • func NewTopicIterator(topics []*api.Topic) *TopicIterator
  • func (t *TopicIterator) Error() error
  • func (t *TopicIterator) Key() []byte
  • func (t *TopicIterator) Next() bool
  • func (t *TopicIterator) NextPage(in *api.PageInfo) (out *api.TopicsPage, err error)
  • func (t *TopicIterator) Prev() bool
  • func (t *TopicIterator) Release()
  • func (t *TopicIterator) Topic() (*api.Topic, error)

Constants

const (
	Close          = "Close"
	ReadOnly       = "ReadOnly"
	AllowedTopics  = "AllowedTopics"
	ListTopics     = "ListTopics"
	CreateTopic    = "CreateTopic"
	RetrieveTopic  = "RetrieveTopic"
	UpdateTopic    = "UpdateTopic"
	DeleteTopic    = "DeleteTopic"
	ListTopicNames = "ListTopicNames"
	TopicExists    = "TopicExists"
	TopicName      = "TopicName"
)

Constants are used to reference store methods in mock code

Functions

func UnmarshalTopicList

func UnmarshalTopicList(data []byte, jsonpb *protojson.UnmarshalOptions) (topics []*api.Topic, err error)

Types

type Store

type Store struct {
	OnClose          func() error
	OnReadOnly       func() bool
	OnAllowedTopics  func(ulid.ULID) ([]ulid.ULID, error)
	OnListTopics     func(ulid.ULID) iterator.TopicIterator
	OnCreateTopic    func(*api.Topic) error
	OnRetrieveTopic  func(topicID ulid.ULID) (*api.Topic, error)
	OnUpdateTopic    func(*api.Topic) error
	OnDeleteTopic    func(topicID ulid.ULID) error
	OnListTopicNames func(ulid.ULID) iterator.TopicNamesIterator
	OnTopicExists    func(*api.TopicName) (*api.TopicExistsInfo, error)
	OnTopicName      func(ulid.ULID) (string, error)
	// contains filtered or unexported fields
}

Implements both a store.EventStore and a store.MetaStore for testing purposes.

func Open

func Open(conf config.StorageConfig) (*Store, error)

func (*Store) AllowedTopics

func (s *Store) AllowedTopics(projectID ulid.ULID) ([]ulid.ULID, error)

func (*Store) Calls

func (s *Store) Calls(call string) int

func (*Store) Close

func (s *Store) Close() error

func (*Store) CreateTopic

func (s *Store) CreateTopic(topic *api.Topic) error

func (*Store) DeleteTopic

func (s *Store) DeleteTopic(topicID ulid.ULID) error

func (*Store) ListTopicNames

func (s *Store) ListTopicNames(projectID ulid.ULID) iterator.TopicNamesIterator

func (*Store) ListTopics

func (s *Store) ListTopics(projectID ulid.ULID) iterator.TopicIterator

func (*Store) ReadOnly

func (s *Store) ReadOnly() bool

func (*Store) Reset

func (s *Store) Reset()

func (*Store) RetrieveTopic

func (s *Store) RetrieveTopic(topicID ulid.ULID) (*api.Topic, error)

func (*Store) TopicExists

func (s *Store) TopicExists(in *api.TopicName) (*api.TopicExistsInfo, error)

func (*Store) TopicName

func (s *Store) TopicName(topicID ulid.ULID) (string, error)

func (*Store) UpdateTopic

func (s *Store) UpdateTopic(topic *api.Topic) error

func (*Store) UseError

func (s *Store) UseError(call string, err error) error

func (*Store) UseFixture

func (s *Store) UseFixture(call, path string) (err error)

type TopicIterator

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

func NewErrorIterator

func NewErrorIterator(err error) *TopicIterator

func NewTopicIterator

func NewTopicIterator(topics []*api.Topic) *TopicIterator

func (*TopicIterator) Error

func (t *TopicIterator) Error() error

func (*TopicIterator) Key

func (t *TopicIterator) Key() []byte

func (*TopicIterator) Next

func (t *TopicIterator) Next() bool

func (*TopicIterator) NextPage

func (t *TopicIterator) NextPage(in *api.PageInfo) (out *api.TopicsPage, err error)

func (*TopicIterator) Prev

func (t *TopicIterator) Prev() bool

func (*TopicIterator) Release

func (t *TopicIterator) Release()

func (*TopicIterator) Topic

func (t *TopicIterator) Topic() (*api.Topic, error)