transport

Documentation

Index

• Constants
• Variables
• func Encode(m Message) ([]byte, error)
• type ForkVersionFormat
  • func (f ForkVersionFormat) String() string
• type Message
  • func Decode(b []byte) (Message, error)
  • func (m Message) Loggable() map[string]any
• type Subscription

Constants

const (
	Unknown = iota
	AltairJson
	BellatrixJson
	CapellaJson
	CapellaSSZ
)

Variables

var (
	ErrDecodeVarint = errors.New("error decoding varint value")
)

Functions

func Encode

func Encode(m Message) ([]byte, error)

Types

type ForkVersionFormat

type ForkVersionFormat uint64

func (ForkVersionFormat) String

func (f ForkVersionFormat) String() string

type Message

type Message struct {
	Source       uuid.UUID
	ForkEncoding ForkVersionFormat
	Payload      []byte
}

func Decode

func Decode(b []byte) (Message, error)

func (Message) Loggable

func (m Message) Loggable() map[string]any

type Subscription

type Subscription interface {
	Next(context.Context) (Message, error)
	Close() error
}