Documentation ¶
Index ¶
Constants ¶
View Source
const ( // Thread is the protocol slug. Thread = "thread" // ThreadCode is the protocol code. ThreadCode = 406 // ThreadsVersion is the current protocol version. ThreadVersion = "0.0.1" // ThreadProtocol is the threads protocol tag. ThreadProtocol protocol.ID = "/" + Thread + "/" + ThreadVersion )
Variables ¶
View Source
var ( // MaxPullLimit is the maximum page size for pulling records. MaxPullLimit = 10000 // InitialPullInterval is the interval between automatic log pulls. InitialPullInterval = time.Second // PullInterval is the interval between automatic log pulls. PullInterval = time.Second * 10 )
Functions ¶
func NewThreads ¶
func NewThreads( ctx context.Context, h host.Host, bstore bs.Blockstore, ds format.DAGService, ts tstore.Threadstore, conf Config, ) (tserv.Threadservice, error)
NewThreads creates an instance of threads from the given host and thread store.
func NewThreadstore ¶
func NewThreadstore(kb tstore.KeyBook, ab tstore.AddrBook, hb tstore.HeadBook, md tstore.ThreadMetadata) tstore.Threadstore
NewThreadstore creates a new thread store from the given books.
Types ¶
Directories ¶
Path | Synopsis |
---|---|
Package eventstore provides a Store which manage models
|
Package eventstore provides a Store which manage models |
examples
|
|
Click to show internal directories.
Click to hide internal directories.