server

type Db interface {
	GetMsg(*RequestSingle) (*Msg, error)
	GetMsgs(*Request) ([]*Msg, error)
	SaveMsgs([]*Msg) error
	GetCount(*RequestCount) (uint64, error)
	GetTopicList() ([]TopicInfo, error)
	DeleteMessages(*RequestDelete) error
}

type Msg struct {
	Topic   string
	Uid     []byte
	Message []byte
}

type MsgDone struct {
	Msgs []*Msg
	Done chan error
}

type PubSub struct {
	Incr  int64
	Subs  map[int64]*Subscribe
	Mutex sync.Mutex
}

type Request struct {
	Topic    string
	Prefixes [][]byte // Filter only these prefixes, e.g. prefix = "b". Ignore Start if more than 1, except overload
	Start    []byte   // Seek to this location to start, e.g. seek to "baltimore", can be overloaded to say last item
	Uids     [][]byte // When set, Start and Prefixes are ignored
	Max      uint32
	Wait     bool
	Newest   bool
	Context  context.Context
}

type RequestCount struct {
	Topic  string
	Prefix []byte
}

type RequestDelete struct {
	Topic string
	Uids  [][]byte
}

type RequestOld struct {
	Topic  string
	Offset uint64
	Max    uint32
	Wait   bool
}

type RequestSingle struct {
	Topic string
	Uid   []byte
}

type Server struct {
	Port    int
	Shard   uint
	Stopped bool

	MsgDoneChan chan *MsgDone
	Timeout     time.Duration
	Grpc        *grpc.Server
	queue_pb.UnimplementedQueueServer
	// contains filtered or unexported fields
}

type Subscribe struct {
	Id       int64
	Shard    uint
	Topic    string
	Start    []byte
	Prefixes [][]byte
	UidChan  chan []byte
	PubSub   *PubSub
}

type TopicInfo struct {
	Name  string
	Count uint64
}