sub

Documentation

Index

• type Post
  • func (r *Post) Listen(ctx context.Context, txHashes [][32]byte) (<-chan *model.Post, error)
• type Profile
  • func (p *Profile) GetProfileChan(ctx context.Context) <-chan *model.Profile
  • func (p *Profile) Listen(ctx context.Context, addresses [][25]byte, fields load.Fields) (<-chan *model.Profile, error)
  • func (p *Profile) ListenFollowers(ctx context.Context, addrs [][25]byte) error
  • func (p *Profile) ListenFollowing(ctx context.Context, addrs [][25]byte) error
  • func (p *Profile) ListenNames(ctx context.Context, addrs [][25]byte) error
  • func (p *Profile) ListenPics(ctx context.Context, addrs [][25]byte) error
  • func (p *Profile) ListenProfiles(ctx context.Context, addrs [][25]byte) error
  • func (p *Profile) SetupAddresses(addresses [][25]byte) error
  • func (p *Profile) SetupFollowersLockHashes(ctx context.Context, fields load.Fields) error
  • func (p *Profile) SetupFollowingLockHashes(ctx context.Context, fields load.Fields) error
• type Room
  • func (r *Room) Listen(ctx context.Context, names []string) (<-chan *model.Post, error)
• type RoomFollow
  • func (r *RoomFollow) Listen(ctx context.Context, addresses [][25]byte) (<-chan *model.RoomFollow, error)

Types

type Post

type Post struct {
	Name         string
	PostHashChan chan [32]byte
	Cancel       context.CancelFunc
}

func (*Post) Listen

func (r *Post) Listen(ctx context.Context, txHashes [][32]byte) (<-chan *model.Post, error)

type Profile

type Profile struct {
	Addresses        [][25]byte
	AddrUpdateChan   chan [25]byte
	Cancel           context.CancelFunc
	NameAddresses    [][25]byte
	ProfileAddresses [][25]byte
	PicAddresses     [][25]byte
}

func (*Profile) GetProfileChan

func (p *Profile) GetProfileChan(ctx context.Context) <-chan *model.Profile

func (*Profile) Listen

func (p *Profile) Listen(ctx context.Context, addresses [][25]byte, fields load.Fields) (<-chan *model.Profile, error)

func (*Profile) ListenFollowers

func (p *Profile) ListenFollowers(ctx context.Context, addrs [][25]byte) error

func (*Profile) ListenFollowing

func (p *Profile) ListenFollowing(ctx context.Context, addrs [][25]byte) error

func (*Profile) ListenNames

func (p *Profile) ListenNames(ctx context.Context, addrs [][25]byte) error

func (*Profile) ListenPics

func (p *Profile) ListenPics(ctx context.Context, addrs [][25]byte) error

func (*Profile) ListenProfiles

func (p *Profile) ListenProfiles(ctx context.Context, addrs [][25]byte) error

func (*Profile) SetupAddresses

func (p *Profile) SetupAddresses(addresses [][25]byte) error

func (*Profile) SetupFollowersLockHashes

func (p *Profile) SetupFollowersLockHashes(ctx context.Context, fields load.Fields) error

func (*Profile) SetupFollowingLockHashes

func (p *Profile) SetupFollowingLockHashes(ctx context.Context, fields load.Fields) error

type Room

type Room struct {
	Name         string
	RoomPostChan chan [32]byte
	Cancel       context.CancelFunc
}

func (*Room) Listen

func (r *Room) Listen(ctx context.Context, names []string) (<-chan *model.Post, error)

type RoomFollow

type RoomFollow struct {
	Name   string
	Cancel context.CancelFunc
}

func (*RoomFollow) Listen

func (r *RoomFollow) Listen(ctx context.Context, addresses [][25]byte) (<-chan *model.RoomFollow, error)