v1

Documentation

Index

• type DataSourceClient
  • func NewDataSourceClient(cc grpc.ClientConnInterface) *DataSourceClient
  • func (d *DataSourceClient) Observe(ctx context.Context, timestamp ocr2plus_types.ReportTimestamp, ...) (v1.Observation, error)
• type DataSourceServer
  • func NewDataSourceServer(impl v1.DataSource) *DataSourceServer
  • func (d *DataSourceServer) Observe(ctx context.Context, request *mercury_v1_pb.ObserveRequest) (*mercury_v1_pb.ObserveResponse, error)
• type ReportCodecClient
  • func NewReportCodecClient(cc grpc.ClientConnInterface) *ReportCodecClient
  • func (r *ReportCodecClient) BuildReport(ctx context.Context, fields mercury_v1_types.ReportFields) (ocr2plus_types.Report, error)
  • func (r *ReportCodecClient) CurrentBlockNumFromReport(ctx context.Context, report ocr2plus_types.Report) (int64, error)
  • func (r *ReportCodecClient) MaxReportLength(ctx context.Context, n int) (int, error)
• type ReportCodecServer
  • func NewReportCodecServer(impl mercury_v1_types.ReportCodec) *ReportCodecServer
  • func (r *ReportCodecServer) BuildReport(ctx context.Context, request *mercury_v1_pb.BuildReportRequest) (*mercury_v1_pb.BuildReportReply, error)
  • func (r *ReportCodecServer) CurrentBlockNumFromReport(ctx context.Context, request *mercury_v1_pb.CurrentBlockNumFromReportRequest) (*mercury_v1_pb.CurrentBlockNumFromReportResponse, error)
  • func (r *ReportCodecServer) MaxReportLength(ctx context.Context, request *mercury_v1_pb.MaxReportLengthRequest) (*mercury_v1_pb.MaxReportLengthReply, error)

Types

type DataSourceClient

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

func NewDataSourceClient

func NewDataSourceClient(cc grpc.ClientConnInterface) *DataSourceClient

func (*DataSourceClient) Observe

func (d *DataSourceClient) Observe(ctx context.Context, timestamp ocr2plus_types.ReportTimestamp, fetchMaxFinalizedTimestamp bool) (v1.Observation, error)

type DataSourceServer

type DataSourceServer struct {
	mercury_v1_pb.UnimplementedDataSourceServer
	// contains filtered or unexported fields
}

func NewDataSourceServer

func NewDataSourceServer(impl v1.DataSource) *DataSourceServer

func (*DataSourceServer) Observe

func (d *DataSourceServer) Observe(ctx context.Context, request *mercury_v1_pb.ObserveRequest) (*mercury_v1_pb.ObserveResponse, error)

type ReportCodecClient

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

func NewReportCodecClient

func NewReportCodecClient(cc grpc.ClientConnInterface) *ReportCodecClient

func (*ReportCodecClient) BuildReport

func (r *ReportCodecClient) BuildReport(ctx context.Context, fields mercury_v1_types.ReportFields) (ocr2plus_types.Report, error)

func (*ReportCodecClient) CurrentBlockNumFromReport

func (r *ReportCodecClient) CurrentBlockNumFromReport(ctx context.Context, report ocr2plus_types.Report) (int64, error)

func (*ReportCodecClient) MaxReportLength

func (r *ReportCodecClient) MaxReportLength(ctx context.Context, n int) (int, error)

type ReportCodecServer

type ReportCodecServer struct {
	mercury_v1_pb.UnimplementedReportCodecServer
	// contains filtered or unexported fields
}

func NewReportCodecServer

func NewReportCodecServer(impl mercury_v1_types.ReportCodec) *ReportCodecServer

func (*ReportCodecServer) BuildReport

func (r *ReportCodecServer) BuildReport(ctx context.Context, request *mercury_v1_pb.BuildReportRequest) (*mercury_v1_pb.BuildReportReply, error)

func (*ReportCodecServer) CurrentBlockNumFromReport

func (r *ReportCodecServer) CurrentBlockNumFromReport(ctx context.Context, request *mercury_v1_pb.CurrentBlockNumFromReportRequest) (*mercury_v1_pb.CurrentBlockNumFromReportResponse, error)

func (*ReportCodecServer) MaxReportLength

func (r *ReportCodecServer) MaxReportLength(ctx context.Context, request *mercury_v1_pb.MaxReportLengthRequest) (*mercury_v1_pb.MaxReportLengthReply, error)