core

Documentation

Index

• Constants
• type Config
• type Core
  • func New(config Config, store *store.Store, notifChan chan types.Notification) *Core
  • func (c *Core) Attestations(ctx context.Context, req *proto.AttestationsRequest) (*proto.DefaultResponse, error)
  • func (c *Core) ChainHead(ctx context.Context, req *proto.ChainHeadRequest) (*proto.ChainHeadResponse, error)
  • func (c *Core) Close()
  • func (c *Core) Connect(ctx context.Context, req *proto.ConnectRequest) (*proto.ConnectResponse, error)
  • func (c *Core) Heartbeat(ctx context.Context, req *proto.HeartbeatRequest) (*proto.HeartbeatResponse, error)
  • func (c *Core) MemoryUsage(ctx context.Context, req *proto.MemoryUsageRequest) (*proto.DefaultResponse, error)
  • func (c *Core) Peers(ctx context.Context, req *proto.PeersRequest) (*proto.DefaultResponse, error)
  • func (c *Core) Run()
  • func (c *Core) Syncing(ctx context.Context, req *proto.SyncingRequest) (*proto.DefaultResponse, error)
  • func (c *Core) Telemetry(ctx context.Context, req *proto.TelemetryRequest) (*proto.TelemetryResponse, error)

Constants

const HeartbeatCheckInterval = 5 * time.Second

const OfflineKickThreshold = 2 * time.Hour

const OfflineTimeout = 30 * time.Second

Types

type Config

type Config struct {
}

type Core

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

func New

func New(config Config, store *store.Store, notifChan chan types.Notification) *Core

func (*Core) Attestations

func (c *Core) Attestations(ctx context.Context, req *proto.AttestationsRequest) (*proto.DefaultResponse, error)

func (*Core) ChainHead

func (c *Core) ChainHead(ctx context.Context, req *proto.ChainHeadRequest) (*proto.ChainHeadResponse, error)

func (*Core) Close

func (c *Core) Close()

func (*Core) Connect

func (c *Core) Connect(ctx context.Context, req *proto.ConnectRequest) (*proto.ConnectResponse, error)

func (*Core) Heartbeat

func (c *Core) Heartbeat(ctx context.Context, req *proto.HeartbeatRequest) (*proto.HeartbeatResponse, error)

func (*Core) MemoryUsage

func (c *Core) MemoryUsage(ctx context.Context, req *proto.MemoryUsageRequest) (*proto.DefaultResponse, error)

func (*Core) Peers

func (c *Core) Peers(ctx context.Context, req *proto.PeersRequest) (*proto.DefaultResponse, error)

func (*Core) Run

func (c *Core) Run()

func (*Core) Syncing

func (c *Core) Syncing(ctx context.Context, req *proto.SyncingRequest) (*proto.DefaultResponse, error)

func (*Core) Telemetry

func (c *Core) Telemetry(ctx context.Context, req *proto.TelemetryRequest) (*proto.TelemetryResponse, error)

Deprecated