heimdallgrpc

Documentation

Index

• func StartHeimdallServer(shutDownCtx context.Context, heimdall heimdall.HeimdallServer, addr string, ...) error
• type HeimdallGRPCClient
  • func NewHeimdallGRPCClient(address string, logger log.Logger) *HeimdallGRPCClient
  • func (h *HeimdallGRPCClient) Close()
  • func (h *HeimdallGRPCClient) FetchCheckpoint(ctx context.Context, number int64) (*checkpoint.Checkpoint, error)
  • func (h *HeimdallGRPCClient) FetchCheckpointCount(ctx context.Context) (int64, error)
  • func (h *HeimdallGRPCClient) FetchLastNoAckMilestone(ctx context.Context) (string, error)
  • func (h *HeimdallGRPCClient) FetchMilestone(ctx context.Context) (*milestone.Milestone, error)
  • func (h *HeimdallGRPCClient) FetchMilestoneCount(ctx context.Context) (int64, error)
  • func (h *HeimdallGRPCClient) FetchMilestoneID(ctx context.Context, milestoneID string) error
  • func (h *HeimdallGRPCClient) FetchNoAckMilestone(ctx context.Context, milestoneID string) error
  • func (h *HeimdallGRPCClient) Span(ctx context.Context, spanID uint64) (*span.HeimdallSpan, error)
  • func (h *HeimdallGRPCClient) StateSyncEvents(ctx context.Context, fromID uint64, to int64) ([]*clerk.EventRecordWithTime, error)
• type HeimdallGRPCServer
  • func (h *HeimdallGRPCServer) FetchCheckpoint(ctx context.Context, in *proto.FetchCheckpointRequest) (*proto.FetchCheckpointResponse, error)
  • func (h *HeimdallGRPCServer) FetchCheckpointCount(ctx context.Context, in *emptypb.Empty) (*proto.FetchCheckpointCountResponse, error)
  • func (h *HeimdallGRPCServer) Span(ctx context.Context, in *proto.SpanRequest) (*proto.SpanResponse, error)
  • func (h *HeimdallGRPCServer) StateSyncEvents(req *proto.StateSyncEventsRequest, reply proto.Heimdall_StateSyncEventsServer) error

Functions

func StartHeimdallServer

func StartHeimdallServer(shutDownCtx context.Context, heimdall heimdall.HeimdallServer, addr string, logger log.Logger) error

StartHeimdallServer creates a heimdall GRPC server - which is implemented via the passed in client interface. It is intended for use in testing where more than a single test validator is required rather than to replace the maticnetwork implementation

Types

type HeimdallGRPCClient

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

func NewHeimdallGRPCClient

func NewHeimdallGRPCClient(address string, logger log.Logger) *HeimdallGRPCClient

func (*HeimdallGRPCClient) Close

func (h *HeimdallGRPCClient) Close()

func (*HeimdallGRPCClient) FetchCheckpoint

func (h *HeimdallGRPCClient) FetchCheckpoint(ctx context.Context, number int64) (*checkpoint.Checkpoint, error)

func (*HeimdallGRPCClient) FetchCheckpointCount

func (h *HeimdallGRPCClient) FetchCheckpointCount(ctx context.Context) (int64, error)

func (*HeimdallGRPCClient) FetchLastNoAckMilestone

func (h *HeimdallGRPCClient) FetchLastNoAckMilestone(ctx context.Context) (string, error)

func (*HeimdallGRPCClient) FetchMilestone

func (h *HeimdallGRPCClient) FetchMilestone(ctx context.Context) (*milestone.Milestone, error)

func (*HeimdallGRPCClient) FetchMilestoneCount

func (h *HeimdallGRPCClient) FetchMilestoneCount(ctx context.Context) (int64, error)

func (*HeimdallGRPCClient) FetchMilestoneID

func (h *HeimdallGRPCClient) FetchMilestoneID(ctx context.Context, milestoneID string) error

func (*HeimdallGRPCClient) FetchNoAckMilestone

func (h *HeimdallGRPCClient) FetchNoAckMilestone(ctx context.Context, milestoneID string) error

func (*HeimdallGRPCClient) Span

func (h *HeimdallGRPCClient) Span(ctx context.Context, spanID uint64) (*span.HeimdallSpan, error)

func (*HeimdallGRPCClient) StateSyncEvents

func (h *HeimdallGRPCClient) StateSyncEvents(ctx context.Context, fromID uint64, to int64) ([]*clerk.EventRecordWithTime, error)

type HeimdallGRPCServer

type HeimdallGRPCServer struct {
	proto.UnimplementedHeimdallServer
	// contains filtered or unexported fields
}

func (*HeimdallGRPCServer) FetchCheckpoint

func (h *HeimdallGRPCServer) FetchCheckpoint(ctx context.Context, in *proto.FetchCheckpointRequest) (*proto.FetchCheckpointResponse, error)

func (*HeimdallGRPCServer) FetchCheckpointCount

func (h *HeimdallGRPCServer) FetchCheckpointCount(ctx context.Context, in *emptypb.Empty) (*proto.FetchCheckpointCountResponse, error)

func (*HeimdallGRPCServer) Span

func (h *HeimdallGRPCServer) Span(ctx context.Context, in *proto.SpanRequest) (*proto.SpanResponse, error)

func (*HeimdallGRPCServer) StateSyncEvents

func (h *HeimdallGRPCServer) StateSyncEvents(req *proto.StateSyncEventsRequest, reply proto.Heimdall_StateSyncEventsServer) error