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(ctx context.Context)
• type ReceiverOption
  • func WithBlockTime(blockTime int64) ReceiverOption
  • func WithPrometheus(prom *prometheus.Service) ReceiverOption
  • func WithStorage(db *database.PgGo) 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(ctx context.Context)

Start -

type ReceiverOption

type ReceiverOption func(*Receiver)

ReceiverOption -

func WithBlockTime

func WithBlockTime(blockTime int64) ReceiverOption

WithBlockTime -

func WithPrometheus

func WithPrometheus(prom *prometheus.Service) ReceiverOption

WithPrometheus -

func WithStorage

func WithStorage(db *database.PgGo) ReceiverOption

WithStorage -

type Status

type Status string

Status

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

Statuses