broadcaster

Documentation

Index

• type Broadcaster
  • func NewBroadcaster(_ context.Context, config *config.File) (*Broadcaster, error)
  • func (b *Broadcaster) Heartbeat(ctx context.Context) error
  • func (b *Broadcaster) Register(ctx context.Context) error
  • func (b *Broadcaster) Run(ctx context.Context) error
• type NodeHeartbeatRequest
• type RegisterNodeRequest

Types

type Broadcaster

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

func NewBroadcaster

func NewBroadcaster(_ context.Context, config *config.File) (*Broadcaster, error)

func (*Broadcaster) Heartbeat

func (b *Broadcaster) Heartbeat(ctx context.Context) error

func (*Broadcaster) Register

func (b *Broadcaster) Register(ctx context.Context) error

func (*Broadcaster) Run

func (b *Broadcaster) Run(ctx context.Context) error

type NodeHeartbeatRequest

type NodeHeartbeatRequest struct {
	Address   common.Address `json:"address" validate:"required"`
	Signature string         `json:"signature" validate:"required"`
	Endpoint  string         `json:"endpoint" validate:"required"`
	Timestamp int64          `json:"timestamp" validate:"required"`
}

type RegisterNodeRequest

type RegisterNodeRequest struct {
	Address     common.Address    `json:"address" validate:"required"`
	Signature   string            `json:"signature" validate:"required"`
	Endpoint    string            `json:"endpoint" validate:"required"`
	AccessToken string            `json:"access_token,omitempty"`
	Stream      *config.Stream    `json:"stream,omitempty"`
	Config      *config.Component `json:"config,omitempty"`
	Type        string            `json:"type" validate:"required"`
}