receiver

Documentation

Index

• type Message
• type Receiver
  • func New(urls []string, network string, opts ...ReceiverOption) (*Receiver, error)
  • func (indexer *Receiver) Close() error
  • func (indexer *Receiver) Operations() <-chan Message
  • func (indexer *Receiver) Start()
• type ReceiverOption
  • func WithInterval(seconds uint64) ReceiverOption
  • func WithStorage(db *gorm.DB, blockTime int64) ReceiverOption
  • func WithTimeout(seconds uint64) ReceiverOption
• type Status

Types

type Message

type Message struct {
	Status   Status
	Protocol string
	Body     interface{}
}

Message -

type Receiver

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

Receiver -

func New

func New(urls []string, network string, opts ...ReceiverOption) (*Receiver, error)

New -

func (*Receiver) Close

func (indexer *Receiver) Close() error

Close -

func (*Receiver) Operations

func (indexer *Receiver) Operations() <-chan Message

Operations -

func (*Receiver) Start

func (indexer *Receiver) Start()

Start -

type ReceiverOption

type ReceiverOption func(*Receiver)

ReceiverOption -

func WithInterval

func WithInterval(seconds uint64) ReceiverOption

WithInterval -

func WithStorage

func WithStorage(db *gorm.DB, blockTime int64) ReceiverOption

WithStorage -

func WithTimeout

func WithTimeout(seconds uint64) ReceiverOption

WithTimeout -

type Status

type Status string

Status

const (
	StatusApplied       Status = "applied"
	StatusBranchDelayed Status = "branch_delayed"
	StatusBranchRefused Status = "branch_refused"
	StatusRefused       Status = "refused"
	StatusUnprocessed   Status = "unprocessed"
)

Statuses