v4

Documentation

Index

• type DataSourceClient
  • func NewDataSourceClient(cc grpc.ClientConnInterface) *DataSourceClient
  • func (d *DataSourceClient) Observe(ctx context.Context, timestamp ocr2plus_types.ReportTimestamp, ...) (v4.Observation, error)
• type DataSourceServer
  • func NewDataSourceServer(impl v4.DataSource) *DataSourceServer
  • func (d *DataSourceServer) Observe(ctx context.Context, request *mercury_v4_pb.ObserveRequest) (*mercury_v4_pb.ObserveResponse, error)
• type ReportCodecClient
  • func NewReportCodecClient(cc grpc.ClientConnInterface) *ReportCodecClient
  • func (r *ReportCodecClient) BuildReport(ctx context.Context, fields mercury_v4_types.ReportFields) (ocr2plus_types.Report, error)
  • func (r *ReportCodecClient) MaxReportLength(ctx context.Context, n int) (int, error)
  • func (r *ReportCodecClient) ObservationTimestampFromReport(ctx context.Context, report ocr2plus_types.Report) (uint32, error)
• type ReportCodecServer
  • func NewReportCodecServer(impl mercury_v4_types.ReportCodec) *ReportCodecServer
  • func (r *ReportCodecServer) BuildReport(ctx context.Context, request *mercury_v4_pb.BuildReportRequest) (*mercury_v4_pb.BuildReportReply, error)
  • func (r *ReportCodecServer) MaxReportLength(ctx context.Context, request *mercury_v4_pb.MaxReportLengthRequest) (*mercury_v4_pb.MaxReportLengthReply, error)
  • func (r *ReportCodecServer) ObservationTimestampFromReport(ctx context.Context, ...) (*mercury_v4_pb.ObservationTimestampFromReportReply, 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) (v4.Observation, error)

type DataSourceServer

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

func NewDataSourceServer

func NewDataSourceServer(impl v4.DataSource) *DataSourceServer

func (*DataSourceServer) Observe

func (d *DataSourceServer) Observe(ctx context.Context, request *mercury_v4_pb.ObserveRequest) (*mercury_v4_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_v4_types.ReportFields) (ocr2plus_types.Report, error)

func (*ReportCodecClient) MaxReportLength

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

func (*ReportCodecClient) ObservationTimestampFromReport

func (r *ReportCodecClient) ObservationTimestampFromReport(ctx context.Context, report ocr2plus_types.Report) (uint32, error)

type ReportCodecServer

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

func NewReportCodecServer

func NewReportCodecServer(impl mercury_v4_types.ReportCodec) *ReportCodecServer

func (*ReportCodecServer) BuildReport

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

func (*ReportCodecServer) MaxReportLength

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

func (*ReportCodecServer) ObservationTimestampFromReport

func (r *ReportCodecServer) ObservationTimestampFromReport(ctx context.Context, request *mercury_v4_pb.ObservationTimestampFromReportRequest) (*mercury_v4_pb.ObservationTimestampFromReportReply, error)