transport

Documentation

Index

• Constants
• Variables
• func Encode(m Message) ([]byte, error)
• type ForkVersionFormat
• type Message
  • func Decode(b []byte) (Message, error)
• 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

type Message

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

func Decode

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

type Subscription

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