extend type Query { posts(name: String!, tag: String! = "", paging: PageInput): Connection! } extend type Subscription { """after == 0 start from begining, after == -1 start from end""" postAdded(name: String!, tag: String! = "", after: Int! = -1): PostEvent } type PostEvent implements Edge @goModel(model: "go.sour.is/tools/app/msgbus.PostEvent") { id: ID! payload: String! payloadJSON: Map! tags: [String!]! meta: Meta! }