views

Documentation

Index

• Variables
• type OpenPolls
  • func NewOpenPolls(eventStore eventstore.EventStore) (*OpenPolls, error)
  • func (o *OpenPolls) Close() error
  • func (o *OpenPolls) List() []interface{}
  • func (o *OpenPolls) Rebuild() (err error)

Variables

var (
	// ErrProcessing returned when a view is already rebuilding.
	ErrProcessing = errors.New("View is already processing")
	// ErrClosed returned when a view has been shutdown and is no longer servicing
	// requests.
	ErrClosed = errors.New("View is not current running")
)

Types

type OpenPolls

type OpenPolls struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

OpenPolls keeps a cache of the current open polls

func NewOpenPolls

func NewOpenPolls(
	eventStore eventstore.EventStore,
) (*OpenPolls, error)

NewOpenPolls creates a new NewOpenPolls

func (*OpenPolls) Close

func (o *OpenPolls) Close() error

Close implements io.Closer, unsubscribes from EventManager and shuts down goroutine.

func (*OpenPolls) List

func (o *OpenPolls) List() []interface{}

List returns list of currently open polls

func (*OpenPolls) Rebuild

func (o *OpenPolls) Rebuild() (err error)

Rebuild triggers the view to rebuild