ev/pkg/es/es.graphqls

type Meta @goModel(model: "github.com/sour-is/ev/pkg/es/event.Meta") {
    eventID: String! @goField(name: "getEventID")
    streamID: String!
    created: Time!
    position: Int!
}

extend type Query {
    events(streamID: String! paging: PageInput): Connection!
}
extend type Subscription {
    """after == 0 start from begining, after == -1 start from end"""
    eventAdded(streamID: String! after: Int! = -1): Event
}

type Event implements Edge @goModel(model: "github.com/sour-is/ev/pkg/es.GQLEvent") {
    id: ID!

    eventID: String!
    values: Map!
    bytes: String!
    meta: Meta!
}