tipubsub

type Config struct {
	// DSN is the data source name.
	DSN string `toml:"dsn" env:"DSN" env-default:"root:@tcp(localhost:4000)/test"`
	// MaxBatchSize is the maximum number of messages to batch a transaction.
	MaxBatchSize int `toml:"max_batch_size" env:"MAX_BATCH_SIZE" env-default:"1000"`
	// PollIntervalInMs is the interval to poll the database.
	PollIntervalInMs int `toml:"poll_interval_in_ms" env:"POLL_INTERVAL_IN_MS" env-default:"100"`
	// GCIntervalInSec is the interval to run garbage collection.
	GCIntervalInSec int `toml:"gc_interval_in_sec" env:"GC_INTERVAL_IN_SEC" env-default:"600"`
	// GCKeepItems is the number of items to keep in the cache.
	GCKeepItems int `toml:"gc_keep_items" env:"GC_KEEP_ITEMS" env-default:"10000"`
}

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

type Message struct {
	ID   int64  `json:"id,string"`
	Ts   int64  `json:"ts,string"`
	Data string `json:"data"`
}

type Offset int64

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

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

type Store interface {
	// Init initializes the store, call it after creating the store
	Init() error
	// CreateStream creates a stream
	CreateStream(streamName string) error
	// PutMessages puts messages into a stream
	PutMessages(streamName string, messages []*Message) error
	// FetchMessages fetches messages from a stream
	FetchMessages(streamName string, offset Offset, limit int) ([]Message, Offset, error)
	// MinMaxID returns the min, max offset of a stream
	MinMaxID(streamName string) (int64, int64, error)
	// GetStreamNames returns the names of all streams
	GetStreamNames() ([]string, error)
	// DB returns the underlying database
	DB() *sql.DB
}

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

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