gql_ev

Documentation

Index

• type Event
  • func (e *Event) Bytes() (string, error)
  • func (e *Event) Created() time.Time
  • func (e *Event) EventID() string
  • func (e *Event) ID() string
  • func (e *Event) IsEdge()
  • func (e *Event) Linked(ctx context.Context) (*Event, error)
  • func (e *Event) Meta() *event.Meta
  • func (e *Event) Position() uint64
  • func (e *Event) StreamID() string
  • func (e *Event) Type() string
  • func (e *Event) Values() map[string]interface{}
• type EventResolver
• type EventStore
  • func (e *EventStore) EventAdded(ctx context.Context, streamID string, after int64) (<-chan *Event, error)
  • func (es *EventStore) Events(ctx context.Context, streamID string, paging *gql.PageInput) (*gql.Connection, error)
  • func (e *EventStore) GetMiddleware() func(http.Handler) http.Handler
  • func (es *EventStore) IsResolver()
  • func (es *EventStore) TruncateStream(ctx context.Context, streamID string, index int64) (bool, error)

Types

type Event

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

func (*Event) Bytes

func (e *Event) Bytes() (string, error)

func (*Event) Created

func (e *Event) Created() time.Time

func (*Event) EventID

func (e *Event) EventID() string

func (*Event) ID

func (e *Event) ID() string

func (*Event) IsEdge

func (e *Event) IsEdge()

func (*Event) Linked

func (e *Event) Linked(ctx context.Context) (*Event, error)

func (*Event) Meta

func (e *Event) Meta() *event.Meta

func (*Event) Position

func (e *Event) Position() uint64

func (*Event) StreamID

func (e *Event) StreamID() string

func (*Event) Type

func (e *Event) Type() string

func (*Event) Values

func (e *Event) Values() map[string]interface{}

type EventResolver

type EventResolver interface {
	Events(ctx context.Context, streamID string, paging *gql.PageInput) (*gql.Connection, error)
	EventAdded(ctx context.Context, streamID string, after int64) (<-chan *Event, error)
	TruncateStream(ctx context.Context, streamID string, index int64) (bool, error)
}

type EventStore

type EventStore struct {
	*ev.EventStore
}

func (*EventStore) EventAdded

func (e *EventStore) EventAdded(ctx context.Context, streamID string, after int64) (<-chan *Event, error)

func (*EventStore) Events

func (es *EventStore) Events(ctx context.Context, streamID string, paging *gql.PageInput) (*gql.Connection, error)

func (*EventStore) GetMiddleware

func (e *EventStore) GetMiddleware() func(http.Handler) http.Handler

func (*EventStore) IsResolver

func (es *EventStore) IsResolver()

func (*EventStore) TruncateStream

func (es *EventStore) TruncateStream(ctx context.Context, streamID string, index int64) (bool, error)