service

Documentation

Index

• func StartSentinelService(cfg *sentinel.SentinelConfig, db persistence.RawBeaconBlockChain, ...) (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) GetPeersStatistics() map[string]*diagnostics.PeerStatistics
  • func (s *SentinelServer) ListenToGossip()
  • 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) SubscribeGossip(_ *sentinelrpc.EmptyMessage, stream sentinelrpc.Sentinel_SubscribeGossipServer) error
• type ServerConfig

Functions

func StartSentinelService

func StartSentinelService(cfg *sentinel.SentinelConfig, db persistence.RawBeaconBlockChain, srvCfg *ServerConfig, creds credentials.TransportCredentials, initialStatus *cltypes.Status, 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) GetPeersStatistics

func (s *SentinelServer) GetPeersStatistics() map[string]*diagnostics.PeerStatistics

func (*SentinelServer) ListenToGossip

func (s *SentinelServer) ListenToGossip()

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) SubscribeGossip

func (s *SentinelServer) SubscribeGossip(_ *sentinelrpc.EmptyMessage, stream sentinelrpc.Sentinel_SubscribeGossipServer) error

type ServerConfig

type ServerConfig struct {
	Network string
	Addr    string
}