event

package

v6.0.5 Latest Latest Go to latest Published: Sep 25, 2025 License: GPL-3.0 Imports: 10 Imported by: 0

Details

View Source

const (
	EventHead = "head"

	EventError           = "error"
	EventConnectionError = "connection_error"
)

View Source

var DefaultEventTopics = []string{EventHead}

This section is empty.

type Event struct {
	EventType string
	Data      []byte
}

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

EventStream is responsible for subscribing to the Beacon API events endpoint and dispatching received events to subscribers.

func NewEventStream(ctx context.Context, httpClient *http.Client, host string, topics []string) (*EventStream, error)

func (h *EventStream) Subscribe(eventsChannel chan<- *Event)

type EventStreamClient interface {
	Subscribe(eventsChannel chan<- *Event)
}