backend

package

v1.13.0 Latest Latest Go to latest Published: Apr 1, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type APIRouter interface {
	AddRPC(route string) error
	AddAPIToRPC(route string, api rpc.API) error
}

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

func NewBackend(log log.Logger, m metrics.Metricer, ensemble *work.Ensemble, jobs work.Jobs, router APIRouter) *Backend

func (ba *Backend) CreateJob(ctx context.Context, id seqtypes.BuilderID, opts *seqtypes.BuildOpts) (work.BuildJob, error)

func (ba *Backend) GetJob(id seqtypes.BuildJobID) work.BuildJob

GetJob returns nil if the job isn't known.

func (ba *Backend) Hello(ctx context.Context, name string) (string, error)

func (ba *Backend) Start(ctx context.Context) error

func (ba *Backend) Stop(ctx context.Context) error

type MockBackend struct{}

func NewMockBackend() *MockBackend

func (ba *MockBackend) CreateJob(ctx context.Context, id seqtypes.BuilderID, opts *seqtypes.BuildOpts) (work.BuildJob, error)

func (ba *MockBackend) GetJob(id seqtypes.BuildJobID) work.BuildJob

func (ba *MockBackend) Hello(ctx context.Context, name string) (string, error)

func (ba *MockBackend) Start(ctx context.Context) error

func (ba *MockBackend) Stop(ctx context.Context) error

func (ba *MockBackend) UnregisterJob(id seqtypes.BuildJobID)