messenger

Documentation

Index

• Constants
• Variables
• type Listener
  • func NewListener(lc fx.Lifecycle, ps *PubSub) (*Listener, error)
  • func (l *Listener) Get(hash string) error
  • func (l *Listener) GetDownloads() []Progress
  • func (l *Listener) SetDownloadFinishHook(di func(string))
  • func (l *Listener) SetDownloadLocation(dl string)
  • func (l *Listener) SetDownloadStartHook(di func(string))
  • func (l *Listener) SetID(id string)
  • func (l *Listener) SetPeer(p ListenerNode) error
• type ListenerNode
• type Message
  • func (m *Message) Marshal() ([]byte, error)
  • func (m *Message) Unmarshal(val []byte) error
• type Progress
• type PubSub
  • func NewPubSub(ps *pubsub.PubSub) (*PubSub, error)
• type Sender
  • func NewSender(ps *PubSub) Sender

Constants

const (
	Topic = "DropCommunication"
)

Variables

var Modules = fx.Options(
	fx.Provide(NewListener),
	fx.Provide(NewSender),
	fx.Provide(NewPubSub),
)

Types

type Listener

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

func NewListener

func NewListener(lc fx.Lifecycle, ps *PubSub) (*Listener, error)

func (*Listener) Get

func (l *Listener) Get(hash string) error

func (*Listener) GetDownloads

func (l *Listener) GetDownloads() []Progress

func (*Listener) SetDownloadFinishHook

func (l *Listener) SetDownloadFinishHook(di func(string))

func (*Listener) SetDownloadLocation

func (l *Listener) SetDownloadLocation(dl string)

func (*Listener) SetDownloadStartHook

func (l *Listener) SetDownloadStartHook(di func(string))

func (*Listener) SetID

func (l *Listener) SetID(id string)

func (*Listener) SetPeer

func (l *Listener) SetPeer(p ListenerNode) error

type ListenerNode

type ListenerNode interface {
	Getter() ipld.DAGService
	Adder(context.Context) func(io.Reader) (ipld.Node, error)
}

type Message

type Message struct {
	Hash []string
}

func (*Message) Marshal

func (m *Message) Marshal() ([]byte, error)

func (*Message) Unmarshal

func (m *Message) Unmarshal(val []byte) error

type Progress

type Progress struct {
	Location string
	Filename string
	Size     int64
	Progress string
}

type PubSub

type PubSub struct {
	*pubsub.Topic
}

func NewPubSub

func NewPubSub(ps *pubsub.PubSub) (*PubSub, error)

type Sender

type Sender interface {
	Send(hash ...string) error
}

func NewSender

func NewSender(ps *PubSub) Sender