Documentation
¶
Index ¶
- func SetupGRPCServer(shutDownCtx context.Context, cdc *codec.Codec, addr string, lggr tmLog.Logger) error
- type Checkpoint
- type Event
- type IrisGRPCServer
- func (h *IrisGRPCServer) FetchCheckpoint(_ context.Context, in *proto.FetchCheckpointRequest) (*proto.FetchCheckpointResponse, error)
- func (h *IrisGRPCServer) FetchCheckpointCount(_ context.Context, _ *emptypb.Empty) (*proto.FetchCheckpointCountResponse, error)
- func (h *IrisGRPCServer) FetchLastNoAckMilestone(ctx context.Context, in *emptypb.Empty) (*proto.FetchLastNoAckMilestoneResponse, error)
- func (h *IrisGRPCServer) FetchMilestone(ctx context.Context, in *emptypb.Empty) (*proto.FetchMilestoneResponse, error)
- func (h *IrisGRPCServer) FetchMilestoneCount(ctx context.Context, in *emptypb.Empty) (*proto.FetchMilestoneCountResponse, error)
- func (h *IrisGRPCServer) FetchMilestoneID(ctx context.Context, in *proto.FetchMilestoneIDRequest) (*proto.FetchMilestoneIDResponse, error)
- func (h *IrisGRPCServer) FetchNoAckMilestone(ctx context.Context, in *proto.FetchMilestoneNoAckRequest) (*proto.FetchMilestoneNoAckResponse, error)
- func (h *IrisGRPCServer) Span(ctx context.Context, in *proto.SpanRequest) (*proto.SpanResponse, error)
- func (h *IrisGRPCServer) StateSyncEvents(req *proto.StateSyncEventsRequest, reply proto.Iris_StateSyncEventsServer) error
- type Milestone
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Checkpoint ¶
type IrisGRPCServer ¶
type IrisGRPCServer struct {
proto.UnimplementedIrisServer
// contains filtered or unexported fields
}
func (*IrisGRPCServer) FetchCheckpoint ¶
func (h *IrisGRPCServer) FetchCheckpoint(_ context.Context, in *proto.FetchCheckpointRequest) (*proto.FetchCheckpointResponse, error)
func (*IrisGRPCServer) FetchCheckpointCount ¶
func (h *IrisGRPCServer) FetchCheckpointCount(_ context.Context, _ *emptypb.Empty) (*proto.FetchCheckpointCountResponse, error)
func (*IrisGRPCServer) FetchLastNoAckMilestone ¶
func (h *IrisGRPCServer) FetchLastNoAckMilestone(ctx context.Context, in *emptypb.Empty) (*proto.FetchLastNoAckMilestoneResponse, error)
func (*IrisGRPCServer) FetchMilestone ¶
func (h *IrisGRPCServer) FetchMilestone(ctx context.Context, in *emptypb.Empty) (*proto.FetchMilestoneResponse, error)
func (*IrisGRPCServer) FetchMilestoneCount ¶
func (h *IrisGRPCServer) FetchMilestoneCount(ctx context.Context, in *emptypb.Empty) (*proto.FetchMilestoneCountResponse, error)
func (*IrisGRPCServer) FetchMilestoneID ¶
func (h *IrisGRPCServer) FetchMilestoneID(ctx context.Context, in *proto.FetchMilestoneIDRequest) (*proto.FetchMilestoneIDResponse, error)
func (*IrisGRPCServer) FetchNoAckMilestone ¶
func (h *IrisGRPCServer) FetchNoAckMilestone(ctx context.Context, in *proto.FetchMilestoneNoAckRequest) (*proto.FetchMilestoneNoAckResponse, error)
func (*IrisGRPCServer) Span ¶
func (h *IrisGRPCServer) Span(ctx context.Context, in *proto.SpanRequest) (*proto.SpanResponse, error)
func (*IrisGRPCServer) StateSyncEvents ¶
func (h *IrisGRPCServer) StateSyncEvents(req *proto.StateSyncEventsRequest, reply proto.Iris_StateSyncEventsServer) error
Click to show internal directories.
Click to hide internal directories.