participants

Documentation

Overview

Package participants contains channel participants iteration helper.

Index

• type Elem
• type GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Admins() *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Banned(paramQ string) *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) BatchSize(batchSize int) *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Bots() *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Channel(paramChannel tg.InputChannelClass) *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Collect(ctx context.Context) ([]Elem, error)
  • func (b *GetParticipantsQueryBuilder) Contacts(paramQ string) *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Count(ctx context.Context) (int, error)
  • func (b *GetParticipantsQueryBuilder) Filter(paramFilter tg.ChannelParticipantsFilterClass) *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) ForEach(ctx context.Context, cb func(context.Context, Elem) error) error
  • func (b *GetParticipantsQueryBuilder) Iter() *Iterator
  • func (b *GetParticipantsQueryBuilder) Kicked(paramQ string) *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Mentions(paramQ string, paramTopMsgID int) *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Query(ctx context.Context, req Request) (tg.ChannelsChannelParticipantsClass, error)
  • func (b *GetParticipantsQueryBuilder) Recent() *GetParticipantsQueryBuilder
  • func (b *GetParticipantsQueryBuilder) Search(paramQ string) *GetParticipantsQueryBuilder
• type Iterator
  • func NewIterator(query Query, limit int) *Iterator
  • func (m *Iterator) Err() error
  • func (m *Iterator) FetchTotal(ctx context.Context) (int, error)
  • func (m *Iterator) Next(ctx context.Context) bool
  • func (m *Iterator) Offset(offset int) *Iterator
  • func (m *Iterator) Total(ctx context.Context) (int, error)
  • func (m *Iterator) Value() Elem
• type Query
• type QueryBuilder
  • func NewQueryBuilder(raw *tg.Client) *QueryBuilder
  • func (q *QueryBuilder) GetParticipants(paramChannel tg.InputChannelClass) *GetParticipantsQueryBuilder
• type QueryFunc
  • func (q QueryFunc) Query(ctx context.Context, req Request) (tg.ChannelsChannelParticipantsClass, error)
• type Request

Types

type Elem

type Elem struct {
	Participant tg.ChannelParticipantClass
	Entities    peer.Entities
}

Elem is a channel participants iterator element.

type GetParticipantsQueryBuilder

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

GetParticipantsQueryBuilder is query builder of ChannelsGetParticipants.

func (*GetParticipantsQueryBuilder) Admins

func (b *GetParticipantsQueryBuilder) Admins() *GetParticipantsQueryBuilder

Admins sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) Banned

func (b *GetParticipantsQueryBuilder) Banned(paramQ string) *GetParticipantsQueryBuilder

Banned sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) BatchSize

func (b *GetParticipantsQueryBuilder) BatchSize(batchSize int) *GetParticipantsQueryBuilder

BatchSize sets buffer of message loaded from one request. Be carefully, when set this limit, because Telegram does not return error if limit is too big, so results can be incorrect.

func (*GetParticipantsQueryBuilder) Bots

func (b *GetParticipantsQueryBuilder) Bots() *GetParticipantsQueryBuilder

Bots sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) Channel

func (b *GetParticipantsQueryBuilder) Channel(paramChannel tg.InputChannelClass) *GetParticipantsQueryBuilder

Channel sets Channel field of GetParticipants query.

func (*GetParticipantsQueryBuilder) Collect

func (b *GetParticipantsQueryBuilder) Collect(ctx context.Context) ([]Elem, error)

Collect creates iterator and collects all elements to slice.

func (*GetParticipantsQueryBuilder) Contacts

func (b *GetParticipantsQueryBuilder) Contacts(paramQ string) *GetParticipantsQueryBuilder

Contacts sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) Count

func (b *GetParticipantsQueryBuilder) Count(ctx context.Context) (int, error)

Count fetches remote state to get number of elements.

func (*GetParticipantsQueryBuilder) Filter

func (b *GetParticipantsQueryBuilder) Filter(paramFilter tg.ChannelParticipantsFilterClass) *GetParticipantsQueryBuilder

Filter sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) ForEach

func (b *GetParticipantsQueryBuilder) ForEach(ctx context.Context, cb func(context.Context, Elem) error) error

ForEach calls given callback on each iterator element.

func (*GetParticipantsQueryBuilder) Iter

func (b *GetParticipantsQueryBuilder) Iter() *Iterator

Iter returns iterator using built query.

func (*GetParticipantsQueryBuilder) Kicked

func (b *GetParticipantsQueryBuilder) Kicked(paramQ string) *GetParticipantsQueryBuilder

Kicked sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) Mentions

func (b *GetParticipantsQueryBuilder) Mentions(paramQ string, paramTopMsgID int) *GetParticipantsQueryBuilder

Mentions sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) Query

func (b *GetParticipantsQueryBuilder) Query(ctx context.Context, req Request) (tg.ChannelsChannelParticipantsClass, error)

Query implements Query interface.

func (*GetParticipantsQueryBuilder) Recent

func (b *GetParticipantsQueryBuilder) Recent() *GetParticipantsQueryBuilder

Recent sets Filter field of GetParticipants query.

func (*GetParticipantsQueryBuilder) Search

func (b *GetParticipantsQueryBuilder) Search(paramQ string) *GetParticipantsQueryBuilder

Search sets Filter field of GetParticipants query.

type Iterator

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

Iterator is a channel participants stream iterator.

func NewIterator

func NewIterator(query Query, limit int) *Iterator

NewIterator creates new iterator.

func (*Iterator) Err

func (m *Iterator) Err() error

Err returns the error, if any, that was encountered during iteration.

func (*Iterator) FetchTotal

func (m *Iterator) FetchTotal(ctx context.Context) (int, error)

FetchTotal fetches and returns count of elements.

func (*Iterator) Next

func (m *Iterator) Next(ctx context.Context) bool

Next prepares the next message for reading with the Value method. It returns true on success, or false if there is no next message or an error happened while preparing it. Err should be consulted to distinguish between the two cases.

func (*Iterator) Offset

func (m *Iterator) Offset(offset int) *Iterator

Offset sets Offset request parameter.

func (*Iterator) Total

func (m *Iterator) Total(ctx context.Context) (int, error)

Total returns last fetched count of elements. If count was not fetched before, it requests server using FetchTotal.

func (*Iterator) Value

func (m *Iterator) Value() Elem

Value returns current message.

type Query

type Query interface {
	Query(ctx context.Context, req Request) (tg.ChannelsChannelParticipantsClass, error)
}

Query is a abstraction for participants request. NB: iterator mutates returned data (sorts, at least).

type QueryBuilder

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

QueryBuilder is a helper to create message queries.

func NewQueryBuilder

func NewQueryBuilder(raw *tg.Client) *QueryBuilder

NewQueryBuilder creates new QueryBuilder.

func (*QueryBuilder) GetParticipants

func (q *QueryBuilder) GetParticipants(paramChannel tg.InputChannelClass) *GetParticipantsQueryBuilder

GetParticipants creates query builder of ChannelsGetParticipants.

type QueryFunc

type QueryFunc func(ctx context.Context, req Request) (tg.ChannelsChannelParticipantsClass, error)

QueryFunc is a function adapter for Query.

func (QueryFunc) Query

func (q QueryFunc) Query(ctx context.Context, req Request) (tg.ChannelsChannelParticipantsClass, error)

Query implements Query interface.

type Request

type Request struct {
	Offset int
	Limit  int
}

Request is a parameter for Query.