autoretrieve

Documentation

Index

• type Autoretrieve
  • func (autoretrieve *Autoretrieve) AddrInfo() (*peer.AddrInfo, error)
• type AutoretrieveInitResponse
• type AutoretrieveListResponse
• type HeartbeatAutoretrieveResponse
• type Iterator
  • func NewIterator(db *gorm.DB, firstContentID uint, count uint) (*Iterator, error)
  • func (iter *Iterator) Next() (multihash.Multihash, error)
• type Provider
  • func NewProvider(db *gorm.DB, advertisementInterval time.Duration, indexerURL string, ...) (*Provider, error)
  • func (provider *Provider) Run(ctx context.Context) error
  • func (provider *Provider) Stop() error
• type PublishedBatch
  • func (PublishedBatch) TableName() string

Types

type Autoretrieve

type Autoretrieve struct {
	gorm.Model

	Handle            string `gorm:"unique"`
	Token             string `gorm:"unique"`
	LastConnection    time.Time
	LastAdvertisement time.Time
	PubKey            string `gorm:"unique"`
	Addresses         string
}

func (*Autoretrieve) AddrInfo

func (autoretrieve *Autoretrieve) AddrInfo() (*peer.AddrInfo, error)

type AutoretrieveInitResponse

type AutoretrieveInitResponse struct {
	Handle            string         `json:"handle"`
	Token             string         `json:"token"`
	LastConnection    time.Time      `json:"lastConnection"`
	AddrInfo          *peer.AddrInfo `json:"addrInfo"`
	AdvertiseInterval string         `json:"advertiseInterval"`
}

type AutoretrieveListResponse

type AutoretrieveListResponse struct {
	Handle            string         `json:"handle"`
	LastConnection    time.Time      `json:"lastConnection"`
	LastAdvertisement time.Time      `json:"lastAdvertisement"`
	AddrInfo          *peer.AddrInfo `json:"addrInfo"`
}

type HeartbeatAutoretrieveResponse

type HeartbeatAutoretrieveResponse struct {
	Handle            string         `json:"handle"`
	LastConnection    time.Time      `json:"lastConnection"`
	LastAdvertisement time.Time      `json:"lastAdvertisement"`
	AddrInfo          *peer.AddrInfo `json:"addrInfo"`
	AdvertiseInterval string         `json:"advertiseInterval"`
}

type Iterator

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

func NewIterator

func NewIterator(db *gorm.DB, firstContentID uint, count uint) (*Iterator, error)

func (*Iterator) Next

func (iter *Iterator) Next() (multihash.Multihash, error)

type Provider

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

func NewProvider

func NewProvider(db *gorm.DB, advertisementInterval time.Duration, indexerURL string, advertiseOffline bool) (*Provider, error)

func (*Provider) Run

func (provider *Provider) Run(ctx context.Context) error

func (*Provider) Stop

func (provider *Provider) Stop() error

type PublishedBatch

type PublishedBatch struct {
	gorm.Model

	FirstContentID     uint
	Count              uint
	AutoretrieveHandle string
}

A batch that has been published for a specific autoretrieve

func (PublishedBatch) TableName

func (PublishedBatch) TableName() string