clients

Documentation

Index

• func GetFullPulse(pn uint32, jetDropContinue []exporter.JetDropContinue) (*exporter.FullPulse, error)
• type TestPulseClient
  • func GetTestPulseClient(pn uint32, err error) *TestPulseClient
  • func (c *TestPulseClient) Export(ctx context.Context, in *exporter.GetPulses, opts ...grpc.CallOption) (exporter.PulseExporter_ExportClient, error)
  • func (c *TestPulseClient) NextFinalizedPulse(ctx context.Context, in *exporter.GetNextFinalizedPulse, ...) (*exporter.FullPulse, error)
  • func (c *TestPulseClient) SetNextFinalizedPulseFunc(importer *heavymock.ImporterServer)
  • func (c *TestPulseClient) TopSyncPulse(ctx context.Context, in *exporter.GetTopSyncPulse, opts ...grpc.CallOption) (*exporter.TopSyncPulseResponse, error)

Functions

func GetFullPulse

func GetFullPulse(pn uint32, jetDropContinue []exporter.JetDropContinue) (*exporter.FullPulse, error)

Types

type TestPulseClient

type TestPulseClient struct {
	NextFinalizedPulseFunc func(ctx context.Context, in *exporter.GetNextFinalizedPulse, opts ...grpc.CallOption) (*exporter.FullPulse, error)
	// contains filtered or unexported fields
}

func GetTestPulseClient

func GetTestPulseClient(pn uint32, err error) *TestPulseClient

func (*TestPulseClient) Export

func (c *TestPulseClient) Export(ctx context.Context, in *exporter.GetPulses, opts ...grpc.CallOption) (exporter.PulseExporter_ExportClient, error)

func (*TestPulseClient) NextFinalizedPulse

func (c *TestPulseClient) NextFinalizedPulse(ctx context.Context, in *exporter.GetNextFinalizedPulse, opts ...grpc.CallOption) (*exporter.FullPulse, error)

func (*TestPulseClient) SetNextFinalizedPulseFunc

func (c *TestPulseClient) SetNextFinalizedPulseFunc(importer *heavymock.ImporterServer)

func (*TestPulseClient) TopSyncPulse

func (c *TestPulseClient) TopSyncPulse(ctx context.Context, in *exporter.GetTopSyncPulse, opts ...grpc.CallOption) (*exporter.TopSyncPulseResponse, error)