ipfs

Documentation

Index

• Variables
• func NewChunkedReader(r io.Reader) *chunkedReader
• type PubSubSubscription
  • func PubSubSubscribe(url, topic string) (*PubSubSubscription, error)
  • func (s *PubSubSubscription) Next() (*Record, error)
• type Record
  • func (r Record) Data() []byte
  • func (r Record) From() peer.ID
  • func (r Record) SeqNo() int64
  • func (r Record) TopicIDs() []string

Variables

var BootstrapPeers = []string{
	"",
}

Functions

func NewChunkedReader

func NewChunkedReader(r io.Reader) *chunkedReader

Types

type PubSubSubscription

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

func PubSubSubscribe

func PubSubSubscribe(url, topic string) (*PubSubSubscription, error)

func (*PubSubSubscription) Next

func (s *PubSubSubscription) Next() (*Record, error)

type Record

type Record struct {
	*pb.Message
}

func (Record) Data

func (r Record) Data() []byte

func (Record) From

func (r Record) From() peer.ID

func (Record) SeqNo

func (r Record) SeqNo() int64

func (Record) TopicIDs

func (r Record) TopicIDs() []string