Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

eventpublisher

package

Go to main page

Versions in this module

v0

v0.2.0

Jan 13, 2023

Changes in this version

+ type Code string

+ const AcceptedCode

+ const ConnectedCode

+ const FailureCode

+ const FirstByteCode

+ const ProposedCode

+ const QueryAskedCode

+ const SuccessCode

+ type Phase string

+ const QueryPhase

+ const RetrievalPhase

+ type RetrievalEvent interface

+ Code func() Code

+ PayloadCid func() cid.Cid

+ Phase func() Phase

+ StorageProviderAddr func() address.Address

+ StorageProviderId func() peer.ID

+ type RetrievalEventAccepted struct

+ func NewRetrievalEventAccepted(phase Phase, payloadCid cid.Cid, storageProviderId peer.ID, ...) RetrievalEventAccepted

+ func (r RetrievalEventAccepted) Code() Code

+ func (r RetrievalEventAccepted) PayloadCid() cid.Cid

+ func (r RetrievalEventAccepted) Phase() Phase

+ func (r RetrievalEventAccepted) StorageProviderAddr() address.Address

+ func (r RetrievalEventAccepted) StorageProviderId() peer.ID

+ type RetrievalEventConnect struct

+ func NewRetrievalEventConnect(phase Phase, payloadCid cid.Cid, storageProviderId peer.ID, ...) RetrievalEventConnect

+ func (r RetrievalEventConnect) Code() Code

+ func (r RetrievalEventConnect) PayloadCid() cid.Cid

+ func (r RetrievalEventConnect) Phase() Phase

+ func (r RetrievalEventConnect) StorageProviderAddr() address.Address

+ func (r RetrievalEventConnect) StorageProviderId() peer.ID

+ type RetrievalEventFailure struct

+ func NewRetrievalEventFailure(phase Phase, payloadCid cid.Cid, storageProviderId peer.ID, ...) RetrievalEventFailure

+ func (r RetrievalEventFailure) Code() Code

+ func (r RetrievalEventFailure) ErrorMessage() string

+ func (r RetrievalEventFailure) PayloadCid() cid.Cid

+ func (r RetrievalEventFailure) Phase() Phase

+ func (r RetrievalEventFailure) StorageProviderAddr() address.Address

+ func (r RetrievalEventFailure) StorageProviderId() peer.ID

+ type RetrievalEventFirstByte struct

+ func NewRetrievalEventFirstByte(phase Phase, payloadCid cid.Cid, storageProviderId peer.ID, ...) RetrievalEventFirstByte

+ func (r RetrievalEventFirstByte) Code() Code

+ func (r RetrievalEventFirstByte) PayloadCid() cid.Cid

+ func (r RetrievalEventFirstByte) Phase() Phase

+ func (r RetrievalEventFirstByte) StorageProviderAddr() address.Address

+ func (r RetrievalEventFirstByte) StorageProviderId() peer.ID

+ type RetrievalEventProposed struct

+ func NewRetrievalEventProposed(phase Phase, payloadCid cid.Cid, storageProviderId peer.ID, ...) RetrievalEventProposed

+ func (r RetrievalEventProposed) Code() Code

+ func (r RetrievalEventProposed) PayloadCid() cid.Cid

+ func (r RetrievalEventProposed) Phase() Phase

+ func (r RetrievalEventProposed) StorageProviderAddr() address.Address

+ func (r RetrievalEventProposed) StorageProviderId() peer.ID

+ type RetrievalEventPublisher struct

+ func NewEventPublisher(ctx context.Context) *RetrievalEventPublisher

+ func (ep *RetrievalEventPublisher) Publish(event RetrievalEvent)

+ func (ep *RetrievalEventPublisher) Subscribe(subscriber RetrievalSubscriber) UnsubscribeFn

+ func (ep *RetrievalEventPublisher) SubscriberCount() int

+ type RetrievalEventQueryAsk struct

+ func NewRetrievalEventQueryAsk(phase Phase, payloadCid cid.Cid, storageProviderId peer.ID, ...) RetrievalEventQueryAsk

+ func (r RetrievalEventQueryAsk) Code() Code

+ func (r RetrievalEventQueryAsk) PayloadCid() cid.Cid

+ func (r RetrievalEventQueryAsk) Phase() Phase

+ func (r RetrievalEventQueryAsk) QueryResponse() retrievalmarket.QueryResponse

+ func (r RetrievalEventQueryAsk) StorageProviderAddr() address.Address

+ func (r RetrievalEventQueryAsk) StorageProviderId() peer.ID

+ type RetrievalEventSuccess struct

+ func NewRetrievalEventSuccess(phase Phase, payloadCid cid.Cid, storageProviderId peer.ID, ...) RetrievalEventSuccess

+ func (r RetrievalEventSuccess) Code() Code

+ func (r RetrievalEventSuccess) Duration() time.Duration

+ func (r RetrievalEventSuccess) PayloadCid() cid.Cid

+ func (r RetrievalEventSuccess) Phase() Phase

+ func (r RetrievalEventSuccess) ReceivedCids() int64

+ func (r RetrievalEventSuccess) ReceivedSize() uint64

+ func (r RetrievalEventSuccess) StorageProviderAddr() address.Address

+ func (r RetrievalEventSuccess) StorageProviderId() peer.ID

+ func (r RetrievalEventSuccess) TotalPayment() big.Int

+ type RetrievalSubscriber interface

+ OnRetrievalEvent func(RetrievalEvent)

+ type UnsubscribeFn func()

v0.1.2

Jan 11, 2023

v0.1.1

Jan 7, 2023

v0.1.0

Jan 6, 2023