store

Documentation

Index

• type Message
• type Q
• type ReadResult
• type Store
  • func New(c *mongo.Client, name string, readCount uint64) Store
• type WriteResult

Types

type Message

type Message struct {
	ID        *primitive.ObjectID `json:"_id" bson:"_id"`
	Data      string              `bson:"data"`
	Q         Q                   `bson:"q"`
	ReadCount uint64              `bson:"readCount"`
}

type Q

type Q struct {
	Name string `json:"name"`
}

type ReadResult

type ReadResult struct {
	Q     Q
	Count int64
	ID    string
}

type Store

type Store interface {
	Insert(ctx context.Context, m Message) (*WriteResult, error)
	Tail(name string) (chan Message, error)
	MarkRead(ctx context.Context, m Message) (*ReadResult, error)
	Create(ctx context.Context, name string, size int64) error
}

func New

func New(c *mongo.Client, name string, readCount uint64) Store

type WriteResult

type WriteResult struct {
	Q  Q
	ID string
}