stores

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 23, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type InMemoryStore

type InMemoryStore struct {
}

InMemoryStore represents simple event store

func (*InMemoryStore) Initialize

func (s *InMemoryStore) Initialize() error

Initialize is invoked once per Storable life cycle to configure the store

func (*InMemoryStore) Store

func (s *InMemoryStore) Store(event *types.SimpleEvent) error

Store persist the SimpleEvent

type PubSubStore

type PubSubStore struct {
	ProjectID string
	TopicName string
	Ctx       context.Context
	// contains filtered or unexported fields
}

PubSubStore pushes events to pubsub topic

func (*PubSubStore) Initialize

func (s *PubSubStore) Initialize() error

Initialize is invoked once per Storable life cycle to configure the store

func (*PubSubStore) Store

func (s *PubSubStore) Store(event *types.SimpleEvent) error

Store persist the SimpleEvent

Jump to

Keyboard shortcuts

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