net

Documentation

Index

• Variables
• func NewNetwork(ctx context.Context, h host.Host, bstore bs.Blockstore, ds format.DAGService, ...) (app.Net, error)
• func NewRecord(r core.Record, id thread.ID, lid peer.ID) core.ThreadRecord
• type Config
• type Handler
• type PubSub
  • func NewPubSub(ctx context.Context, host peer.ID, ps *pubsub.PubSub, handler Handler) *PubSub
  • func (s *PubSub) Add(id thread.ID) error
  • func (s *PubSub) Publish(ctx context.Context, id thread.ID, req *pb.PushRecordRequest) error
  • func (s *PubSub) Remove(id thread.ID) error
• type Record
  • func (r *Record) LogID() peer.ID
  • func (r *Record) ThreadID() thread.ID
  • func (r *Record) Value() core.Record

Variables

var (
	// DialTimeout is the max time duration to wait when dialing a peer.
	DialTimeout = time.Second * 10
	PushTimeout = time.Second * 10
	PullTimeout = time.Second * 10
)

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 NewNetwork

func NewNetwork(
	ctx context.Context,
	h host.Host,
	bstore bs.Blockstore,
	ds format.DAGService,
	ls lstore.Logstore,
	conf Config,
	serverOptions []grpc.ServerOption,
	dialOptions []grpc.DialOption,
) (app.Net, error)

NewNetwork creates an instance of net from the given host and thread store.

func NewRecord

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

NewRecord returns a record with the given values.

Types

type Config

type Config struct {
	Debug  bool
	PubSub bool
}

Config is used to specify thread instance options.

type Handler

type Handler func(context.Context, *pb.PushRecordRequest)

Handler receives all pushed thread records.

type PubSub

type PubSub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

PubSub manages thread pubsub topics.

func NewPubSub

func NewPubSub(ctx context.Context, host peer.ID, ps *pubsub.PubSub, handler Handler) *PubSub

NewPubSub returns a new thread topic manager.

func (*PubSub) Add

func (s *PubSub) Add(id thread.ID) error

Add a new thread topic. This may be called repeatedly for the same thread.

func (*PubSub) Publish

func (s *PubSub) Publish(ctx context.Context, id thread.ID, req *pb.PushRecordRequest) error

Publish a record request to a thread.

func (*PubSub) Remove

func (s *PubSub) Remove(id thread.ID) error

Remove a thread topic. This may be called repeatedly for the same thread.

type Record

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

Record implements core.Record. The most basic component of a Log.

func (*Record) LogID

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

func (*Record) ThreadID

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

func (*Record) Value

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