distributed

Documentation

Index

• Constants
• Variables
• func NeedById(id string) ([]byte, error)
• type ContentNode
  • func Connect(conf *config.AppConfig) *ContentNode
  • func NewNode(ctx context.Context, addr []string, bootstrap string) *ContentNode
  • func (node *ContentNode) ID() string
  • func (node *ContentNode) Join(s string) (*pubsub.Topic, error)
  • func (node *ContentNode) PeerID() peer.ID

Constants

const (
	NEED_BROADCAST_TOPIC                = "need-broadcast-topic"
	IMAGE_TRANSFER_PROTOCOL protocol.ID = "/permit-image-transfer/0.0.1"
)

Variables

var IsUp = false

Functions

func NeedById

func NeedById(id string) ([]byte, error)

Types

type ContentNode

type ContentNode struct {
	Topics map[string]*pubsub.Topic
	// contains filtered or unexported fields
}

var Node *ContentNode

func Connect

func Connect(conf *config.AppConfig) *ContentNode

func NewNode

func NewNode(ctx context.Context, addr []string, bootstrap string) *ContentNode

func (*ContentNode) ID

func (node *ContentNode) ID() string

func (*ContentNode) Join

func (node *ContentNode) Join(s string) (*pubsub.Topic, error)

func (*ContentNode) PeerID

func (node *ContentNode) PeerID() peer.ID