observer

type Block[T any] struct {
	Channel string
	Block   T
}

type BlocksStream[T any] struct {
	// contains filtered or unexported fields
}

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

type ChannelBlocks[T any] struct {
	// pointer is to use Channel's data, which can be changed
	*Channel
	// contains filtered or unexported fields
}

type ChannelBlocksCommon struct {
	*ChannelBlocks[*common.Block]
}

type ChannelBlocksOpt func(*ChannelBlocksOpts)

type ChannelBlocksOpts struct {
	*Opts
	// contains filtered or unexported fields
}

type ChannelBlocksParsed struct {
	*ChannelBlocks[*hlfproto.Block]
}

type ChannelBlocksWithName[T any] struct {
	Name   string
	Blocks <-chan *Block[T]
}

type ChannelInfo struct {
	Channel   string
	Height    uint64
	UpdatedAt *timestamppb.Timestamp
}

type ChannelMatched struct {
	Name string
	// name from settings that lead to this subscription
	MatchPattern    string
	NotMatchPattern string
}

type ChannelObserverStatus int

type ChannelToMatch struct {
	Name            string `json:"name" yaml:"name"`
	MatchPattern    string `json:"match_pattern" yaml:"matchPattern"`
	NotMatchPattern string `json:"not_match_pattern" yaml:"notMatchPattern"`
}

type ChannelWithChannels[T any] struct {
	// contains filtered or unexported fields
}

type ChannelsBlocksPeer[T any] struct {
	// contains filtered or unexported fields
}

type ChannelsBlocksPeerCommon struct {
	*ChannelsBlocksPeer[*common.Block]
}

type ChannelsBlocksPeerOpt func(*ChannelsBlocksPeerOpts)

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

type ChannelsBlocksPeerParsed struct {
	*ChannelsBlocksPeer[*hlfproto.Block]
}

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

type CreateBlockStream[T any] func(context.Context) (<-chan T, error)

type CreateBlockStreamWithRetry[T any] func(context.Context, CreateBlockStream[T]) (<-chan T, error)

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

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

type PeerChannelsFetcher interface {
	URI() string
	api.ChannelListGetter
	api.ChainInfoGetter
}

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

type PeerChannelsGetter interface {
	URI() string
	Channels() map[string]*ChannelInfo
}

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

type PeerChannelsOpt func(*PeerChannelsOpts)

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

type PeerReader interface {
	PeerChannelsFetcher
	api.BlocksDeliverer
	api.ParsedBlocksDeliverer
}

type SeekFromFetcher func(ctx context.Context, channel string) (uint64, error)

type Stream[T any] interface {
	Subscribe() (ch <-chan *Block[T], closer func())
}