service

Documentation

Index

• Variables
• func NewRecord(r core.Record, id thread.ID, lid peer.ID) core.ThreadRecord
• func NewService(ctx context.Context, h host.Host, bstore bs.Blockstore, ds format.DAGService, ...) (core.Service, error)
• type Config
• type Record
  • func (r *Record) LogID() peer.ID
  • func (r *Record) ThreadID() thread.ID
  • func (r *Record) Value() core.Record

Variables

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 NewRecord

func NewRecord(r core.Record, id thread.ID, lid peer.ID) core.ThreadRecord

NewRecord returns a record with the given values.

func NewService

func NewService(
	ctx context.Context,
	h host.Host,
	bstore bs.Blockstore,
	ds format.DAGService,
	ls lstore.Logstore,
	conf Config,
	opts ...grpc.ServerOption,
) (core.Service, error)

NewService creates an instance of service from the given host and thread store.

Types

type Config

type Config struct {
	Debug bool
}

Config is used to specify thread instance options.

type Record

type Record struct {
	core.Record
	// contains filtered or unexported fields
}

Record wraps a core.Record within a thread and log context.

func (*Record) LogID

func (r *Record) LogID() peer.ID

LogID returns the record's log ID.

func (*Record) ThreadID

func (r *Record) ThreadID() thread.ID

ThreadID returns the record's thread ID.

func (*Record) Value

func (r *Record) Value() core.Record

Value returns the underlying record.