service

Documentation

Index

• Constants
• func StartSentinelService(cfg *sentinel.SentinelConfig, blockReader freezeblocks.BeaconSnapshotReader, ...) (sentinelrpc.SentinelClient, error)
• func StartServe(server *SentinelServer, srvCfg *ServerConfig, ...)
• type SentinelServer
  • func NewSentinelServer(ctx context.Context, sentinel *sentinel.Sentinel, logger log.Logger) *SentinelServer
  • func (s *SentinelServer) BanPeer(_ context.Context, p *sentinelrpc.Peer) (*sentinelrpc.EmptyMessage, error)
  • func (s *SentinelServer) GetPeers(_ context.Context, _ *sentinelrpc.EmptyMessage) (*sentinelrpc.PeerCount, error)
  • func (s *SentinelServer) Identity(ctx context.Context, in *sentinelrpc.EmptyMessage) (*sentinelrpc.IdentityResponse, error)
  • func (s *SentinelServer) ListenToGossip()
  • func (s *SentinelServer) PeersInfo(ctx context.Context, r *sentinelrpc.PeersInfoRequest) (*sentinelrpc.PeersInfoResponse, error)
  • func (s *SentinelServer) PublishGossip(_ context.Context, msg *sentinelrpc.GossipData) (*sentinelrpc.EmptyMessage, error)
  • func (s *SentinelServer) SendRequest(ctx context.Context, req *sentinelrpc.RequestData) (*sentinelrpc.ResponseData, error)
  • func (s *SentinelServer) SetStatus(_ context.Context, req *sentinelrpc.Status) (*sentinelrpc.EmptyMessage, error)
  • func (s *SentinelServer) SetSubscribeExpiry(ctx context.Context, expiryReq *sentinelrpc.RequestSubscribeExpiry) (*sentinelrpc.EmptyMessage, error)
  • func (s *SentinelServer) SubscribeGossip(data *sentinelrpc.SubscriptionData, ...) error
• type ServerConfig

Constants

const AttestationSubnetSubscriptions = 2

Functions

func StartSentinelService

func StartSentinelService(
	cfg *sentinel.SentinelConfig,
	blockReader freezeblocks.BeaconSnapshotReader,
	blobStorage blob_storage.BlobStorage,
	indiciesDB kv.RwDB,
	srvCfg *ServerConfig,
	ethClock eth_clock.EthereumClock,
	forkChoiceReader forkchoice.ForkChoiceStorageReader,
	logger log.Logger) (sentinelrpc.SentinelClient, error)

func StartServe

func StartServe(
	server *SentinelServer,
	srvCfg *ServerConfig,
	creds credentials.TransportCredentials,
)

Types

type SentinelServer

type SentinelServer struct {
	sentinelrpc.UnimplementedSentinelServer
	// contains filtered or unexported fields
}

func NewSentinelServer

func NewSentinelServer(ctx context.Context, sentinel *sentinel.Sentinel, logger log.Logger) *SentinelServer

func (*SentinelServer) BanPeer

func (s *SentinelServer) BanPeer(_ context.Context, p *sentinelrpc.Peer) (*sentinelrpc.EmptyMessage, error)

func (*SentinelServer) GetPeers

func (s *SentinelServer) GetPeers(_ context.Context, _ *sentinelrpc.EmptyMessage) (*sentinelrpc.PeerCount, error)

func (*SentinelServer) Identity

func (s *SentinelServer) Identity(ctx context.Context, in *sentinelrpc.EmptyMessage) (*sentinelrpc.IdentityResponse, error)

func (*SentinelServer) ListenToGossip

func (s *SentinelServer) ListenToGossip()

func (*SentinelServer) PeersInfo

func (s *SentinelServer) PeersInfo(ctx context.Context, r *sentinelrpc.PeersInfoRequest) (*sentinelrpc.PeersInfoResponse, error)

func (*SentinelServer) PublishGossip

func (s *SentinelServer) PublishGossip(_ context.Context, msg *sentinelrpc.GossipData) (*sentinelrpc.EmptyMessage, error)

func (*SentinelServer) SendRequest

func (s *SentinelServer) SendRequest(ctx context.Context, req *sentinelrpc.RequestData) (*sentinelrpc.ResponseData, error)

func (*SentinelServer) SetStatus

func (s *SentinelServer) SetStatus(_ context.Context, req *sentinelrpc.Status) (*sentinelrpc.EmptyMessage, error)

func (*SentinelServer) SetSubscribeExpiry

func (s *SentinelServer) SetSubscribeExpiry(ctx context.Context, expiryReq *sentinelrpc.RequestSubscribeExpiry) (*sentinelrpc.EmptyMessage, error)

func (*SentinelServer) SubscribeGossip

func (s *SentinelServer) SubscribeGossip(data *sentinelrpc.SubscriptionData, stream sentinelrpc.Sentinel_SubscribeGossipServer) error

type ServerConfig

type ServerConfig struct {
	Network       string
	Addr          string
	Creds         credentials.TransportCredentials
	InitialStatus *cltypes.Status
}