v2

package
v0.9.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 2, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) (v2.Observation, error)

type DataSourceServer 

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

func NewDataSourceServer 

func NewDataSourceServer(impl v2.DataSource) *DataSourceServer

func (*DataSourceServer) Observe 

func (d *DataSourceServer) Observe(ctx context.Context, request *mercury_v2_pb.ObserveRequest) (*mercury_v2_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_v2_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_v2_pb.UnimplementedReportCodecServer
	// contains filtered or unexported fields
}

func NewReportCodecServer 

func NewReportCodecServer(impl mercury_v2_types.ReportCodec) *ReportCodecServer

func (*ReportCodecServer) BuildReport 

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

func (*ReportCodecServer) MaxReportLength 

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

func (*ReportCodecServer) ObservationTimestampFromReport 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.