server

type Server struct {
	Subscribers map[int64]*Subscriber

	Consumer *consumer.Consumer
	// contains filtered or unexported fields
}

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

type SubscriberOptions struct {
	WantedCollections   *WantedCollections
	WantedDIDs          map[string]struct{}
	MaxMessageSizeBytes uint32
	Compress            bool
	Cursor              *int64
}

type SubscriberOptionsUpdatePayload struct {
	WantedCollections   []string `json:"wantedCollections"`
	WantedDIDs          []string `json:"wantedDids"`
	MaxMessageSizeBytes int      `json:"maxMessageSizeBytes"`
}

type SubscriberSourcedMessage struct {
	Type    string          `json:"type"`
	Payload json.RawMessage `json:"payload"`
}

type WantedCollections struct {
	Prefixes  []string
	FullPaths map[string]struct{}
}