test

package
v0.0.0-...-47b5856 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2024 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const ConfigTOML = `[Foo]
Bar = "Baz"
`
View Source 
const LoggerTestName = "server-side-logger-name"
View Source 
const PluginLoggerTestName = "logger-test"
View Source 
const ReportingPluginWithMedianProviderName = "reporting-plugin-with-median-provider"

Variables

View Source 
var (
	PluginArgs = types.PluginArgs{
		TransmitterID: "testtransmitter",
		PluginConfig:  []byte{100: 88},
	}

	RelayArgs = types.RelayArgs{
		ExternalJobID: uuid.MustParse("1051429b-aa66-11ed-b0d2-5cff35dfbe67"),
		JobID:         123,
		ContractID:    "testcontract",
		New:           true,
		RelayConfig:   []byte{42: 11},
		ProviderType:  string(types.Median),
	}
)

Functions

func PluginLoggerTestHandshakeConfig 

func PluginLoggerTestHandshakeConfig() plugin.HandshakeConfig

func PluginMedian 

func PluginMedian(t *testing.T, p types.PluginMedian)

func PluginTest 

func PluginTest[I any](t *testing.T, name string, p plugin.Plugin, testFn func(*testing.T, I))

func ReportingPluginFactory 

func ReportingPluginFactory(t *testing.T, factory types.ReportingPluginFactory)

func RunPluginRelayer 

func RunPluginRelayer(t *testing.T, p internal.PluginRelayer)

func RunRelayer 

func RunRelayer(t *testing.T, relayer internal.Relayer)

func StaticDataSource 

func StaticDataSource() median.DataSource

func StaticJuelsPerFeeCoinDataSource 

func StaticJuelsPerFeeCoinDataSource() median.DataSource

func Telemetry 

func Telemetry(t *testing.T)

func WrapChainReaderTesterForLoop 

func WrapChainReaderTesterForLoop(wrapped interfacetests.ChainReaderInterfaceTester) interfacetests.ChainReaderInterfaceTester

WrapChainReaderTesterForLoop allows you to test a [types.ChainReader] implementation behind a LOOP server

func WrapCodecTesterForLoop 

func WrapCodecTesterForLoop(wrapped interfacetests.CodecInterfaceTester) interfacetests.CodecInterfaceTester

WrapCodecTesterForLoop allows you to test a [types.Codec] implementation behind a LOOP server

Types

type GRPCPluginLoggerTest 

type GRPCPluginLoggerTest struct {
	plugin.NetRPCUnsupportedPlugin

	logger.Logger
}

NOTE: This is part of the test package because it needs to be imported by the test binary at `./internal/test/cmd` as well as the test at `./pkg/loop/logger_loop_test.go`

func (*GRPCPluginLoggerTest) ClientConfig 

func (g *GRPCPluginLoggerTest) ClientConfig() *plugin.ClientConfig

func (*GRPCPluginLoggerTest) GRPCClient 

func (g *GRPCPluginLoggerTest) GRPCClient(context.Context, *plugin.GRPCBroker, *grpc.ClientConn) (interface{}, error)

func (*GRPCPluginLoggerTest) GRPCServer 

func (g *GRPCPluginLoggerTest) GRPCServer(*plugin.GRPCBroker, *grpc.Server) (err error)

type HelperProcessCommand 

type HelperProcessCommand struct {
	Limit           int
	CommandLocation string
	Command         string
}

func (HelperProcessCommand) New 

func (h HelperProcessCommand) New() *exec.Cmd

type MockConn 

type MockConn struct {
	grpc.ClientConnInterface
}

type PluginMedianTest 

type PluginMedianTest struct {
	types.MedianProvider
}

func (PluginMedianTest) TestPluginMedian 

func (m PluginMedianTest) TestPluginMedian(t *testing.T, p types.PluginMedian)

type StaticErrorLog 

type StaticErrorLog struct{}

func (*StaticErrorLog) SaveError 

func (s *StaticErrorLog) SaveError(ctx context.Context, msg string) error

type StaticKeystore 

type StaticKeystore struct{}

func (StaticKeystore) Accounts 

func (s StaticKeystore) Accounts(ctx context.Context) (accounts []string, err error)

func (StaticKeystore) Sign 

func (s StaticKeystore) Sign(ctx context.Context, id string, data []byte) ([]byte, error)

type StaticMedianProvider 

type StaticMedianProvider struct{}

func (StaticMedianProvider) ChainReader 

func (s StaticMedianProvider) ChainReader() types.ChainReader

func (StaticMedianProvider) Close 

func (s StaticMedianProvider) Close() error

func (StaticMedianProvider) Codec 

func (s StaticMedianProvider) Codec() types.Codec

func (StaticMedianProvider) ContractConfigTracker 

func (s StaticMedianProvider) ContractConfigTracker() libocr.ContractConfigTracker

func (StaticMedianProvider) ContractTransmitter 

func (s StaticMedianProvider) ContractTransmitter() libocr.ContractTransmitter

func (StaticMedianProvider) HealthReport 

func (s StaticMedianProvider) HealthReport() map[string]error

func (StaticMedianProvider) MedianContract 

func (s StaticMedianProvider) MedianContract() median.MedianContract

func (StaticMedianProvider) Name 

func (s StaticMedianProvider) Name() string

func (StaticMedianProvider) OffchainConfigDigester 

func (s StaticMedianProvider) OffchainConfigDigester() libocr.OffchainConfigDigester

func (StaticMedianProvider) OnchainConfigCodec 

func (s StaticMedianProvider) OnchainConfigCodec() median.OnchainConfigCodec

func (StaticMedianProvider) Ready 

func (s StaticMedianProvider) Ready() error

func (StaticMedianProvider) ReportCodec 

func (s StaticMedianProvider) ReportCodec() median.ReportCodec

func (StaticMedianProvider) Start 

func (s StaticMedianProvider) Start(ctx context.Context) error

type StaticPipelineRunnerService 

type StaticPipelineRunnerService struct{}

func (*StaticPipelineRunnerService) ExecuteRun 

func (pr *StaticPipelineRunnerService) ExecuteRun(ctx context.Context, s string, v types.Vars, o types.Options) (types.TaskResults, error)

type StaticPluginMedian 

type StaticPluginMedian struct{}

func (StaticPluginMedian) NewMedianFactory 

func (s StaticPluginMedian) NewMedianFactory(ctx context.Context, provider types.MedianProvider, dataSource, juelsPerFeeCoinDataSource median.DataSource, errorLog types.ErrorLog) (types.ReportingPluginFactory, error)

type StaticPluginProvider 

type StaticPluginProvider struct{}

func (StaticPluginProvider) ChainReader 

func (s StaticPluginProvider) ChainReader() types.ChainReader

func (StaticPluginProvider) Close 

func (s StaticPluginProvider) Close() error

func (StaticPluginProvider) Codec 

func (s StaticPluginProvider) Codec() types.Codec

func (StaticPluginProvider) ContractConfigTracker 

func (s StaticPluginProvider) ContractConfigTracker() libocr.ContractConfigTracker

func (StaticPluginProvider) ContractTransmitter 

func (s StaticPluginProvider) ContractTransmitter() libocr.ContractTransmitter

func (StaticPluginProvider) HealthReport 

func (s StaticPluginProvider) HealthReport() map[string]error

func (StaticPluginProvider) Name 

func (s StaticPluginProvider) Name() string

func (StaticPluginProvider) OffchainConfigDigester 

func (s StaticPluginProvider) OffchainConfigDigester() libocr.OffchainConfigDigester

func (StaticPluginProvider) Ready 

func (s StaticPluginProvider) Ready() error

func (StaticPluginProvider) Start 

func (s StaticPluginProvider) Start(ctx context.Context) error

type StaticPluginRelayer 

type StaticPluginRelayer struct{}

func (StaticPluginRelayer) NewRelayer 

func (s StaticPluginRelayer) NewRelayer(ctx context.Context, config string, keystore types.Keystore) (internal.Relayer, error)

type StaticReportingPluginWithMedianProvider 

type StaticReportingPluginWithMedianProvider struct {
}

func (StaticReportingPluginWithMedianProvider) ConnToProvider 

func (s StaticReportingPluginWithMedianProvider) ConnToProvider(conn grpc.ClientConnInterface, broker internal.Broker, brokerConfig internal.BrokerConfig) types.MedianProvider

func (StaticReportingPluginWithMedianProvider) NewReportingPluginFactory 

func (s StaticReportingPluginWithMedianProvider) NewReportingPluginFactory(ctx context.Context, config types.ReportingPluginServiceConfig, provider types.MedianProvider, pipelineRunner types.PipelineRunnerService, telemetry types.TelemetryClient, errorLog types.ErrorLog) (types.ReportingPluginFactory, error)

type StaticReportingPluginWithPluginProvider 

type StaticReportingPluginWithPluginProvider struct {
}

func (StaticReportingPluginWithPluginProvider) ConnToProvider 

func (s StaticReportingPluginWithPluginProvider) ConnToProvider(conn grpc.ClientConnInterface, broker internal.Broker, brokerConfig internal.BrokerConfig) types.PluginProvider

func (StaticReportingPluginWithPluginProvider) NewReportingPluginFactory 

func (s StaticReportingPluginWithPluginProvider) NewReportingPluginFactory(ctx context.Context, config types.ReportingPluginServiceConfig, provider types.PluginProvider, pipelineRunner types.PipelineRunnerService, telemetry types.TelemetryClient, errorLog types.ErrorLog) (types.ReportingPluginFactory, error)

type StaticTelemetry 

type StaticTelemetry struct{}

func (StaticTelemetry) NewEndpoint 

func (s StaticTelemetry) NewEndpoint(ctx context.Context, network string, chainID string, contractID string, telemType string) (types.TelemetryClientEndpoint, error)

func (StaticTelemetry) Send 

func (s StaticTelemetry) Send(ctx context.Context, n string, chid string, conid string, t string, p []byte) 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.