rpc

type CreateSnapshotViewReply struct {
	ID         string    `json:"id"`
	Subscriber string    `json:"subscriber"`
	Collection string    `json:"collection"`
	CreatedAt  time.Time `json:"createAt"`
}

type CreateSnapshotViewRequest struct {
	Subscriber string `json:"subscriber"`
	Collection string `json:"collection"`
}

type DeleteSnapshotViewReply struct {
	ID string `json:"id"`
}

type DeleteSnapshotViewRequest struct {
	ID string `json:"id"`
}

type Error struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type ErrorReply struct {
	Error *Error `json:"error"`
}

type PullSnapshotViewReply struct {
	ID    string `json:"id"`
	Count int    `json:"count"`
}

type PullSnapshotViewRequest struct {
	ID           string `json:"id"`
	LastKey      string `json:"lastKey"`
	AfterLastKey bool   `json:"afterLastKey"`
}

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

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