testpachd

Documentation

Index

• func AuthMiddlewareInterceptor(mock *MockPachd) grpcutil.Interceptor
• type FindCommitsFunc
• type InterceptorOption
• type MockEnv
  • func NewMockEnv(rctx context.Context, t testing.TB, options ...InterceptorOption) *MockEnv
• type MockPPSJobFinisher
  • func (mpp *MockPPSJobFinisher) FinishJob(*pfs.CommitInfo)
  • func (mpp *MockPPSJobFinisher) Run(context.Context) error
• type MockPPSJobStopper
  • func (mpp *MockPPSJobStopper) Run(context.Context) error
  • func (mpp *MockPPSJobStopper) StopJob(*pfs.Commit)
  • func (mpp *MockPPSJobStopper) StopJobSet(*pfs.CommitSet)
• type MockPPSPropagater
  • func (mpp *MockPPSPropagater) PropagateJobs()
  • func (mpp *MockPPSPropagater) Run(context.Context) error
• type MockPPSTransactionServer
  • func NewMockPPSTransactionServer() *MockPPSTransactionServer
• type MockPachd
  • func NewMockPachd(ctx context.Context, port uint16, options ...InterceptorOption) (*MockPachd, error)
  • func (mock *MockPachd) Close() error
  • func (mock *MockPachd) Err() <-chan error
• type RotateRootTokenFunc

Functions

func AuthMiddlewareInterceptor

func AuthMiddlewareInterceptor(mock *MockPachd) grpcutil.Interceptor

Types

type FindCommitsFunc

type FindCommitsFunc func(*pfs.FindCommitsRequest, pfs.API_FindCommitsServer) error

type InterceptorOption

type InterceptorOption func(mock *MockPachd) grpcutil.Interceptor

type MockEnv

type MockEnv struct {
	testetcd.Env
	MockPachd  *MockPachd
	PachClient *client.APIClient
}

MockEnv contains the basic setup for running end-to-end pachyderm tests entirely locally within the test process. It provides a temporary directory for storing data, an embedded etcd server with a connected client, as well as a local mock pachd instance which allows a test to hook into any pachd calls.

func NewMockEnv

func NewMockEnv(rctx context.Context, t testing.TB, options ...InterceptorOption) *MockEnv

NewMockEnv constructs a MockEnv for testing, which will be destroyed at the end of the test.

type MockPPSJobFinisher

type MockPPSJobFinisher struct{}

func (*MockPPSJobFinisher) FinishJob

func (mpp *MockPPSJobFinisher) FinishJob(*pfs.CommitInfo)

func (*MockPPSJobFinisher) Run

func (mpp *MockPPSJobFinisher) Run(context.Context) error

type MockPPSJobStopper

type MockPPSJobStopper struct{}

func (*MockPPSJobStopper) Run

func (mpp *MockPPSJobStopper) Run(context.Context) error

func (*MockPPSJobStopper) StopJob

func (mpp *MockPPSJobStopper) StopJob(*pfs.Commit)

func (*MockPPSJobStopper) StopJobSet

func (mpp *MockPPSJobStopper) StopJobSet(*pfs.CommitSet)

type MockPPSPropagater

type MockPPSPropagater struct{}

func (*MockPPSPropagater) PropagateJobs

func (mpp *MockPPSPropagater) PropagateJobs()

func (*MockPPSPropagater) Run

func (mpp *MockPPSPropagater) Run(context.Context) error

type MockPPSTransactionServer

type MockPPSTransactionServer struct {
	Api                          ppsTransactionAPI
	NewPropagater                mockNewPropagater
	NewJobStopper                mockNewJobStopper
	NewJobFinisher               mockNewJobFinisher
	StopJobInTransaction         mockStopJobInTransaction
	UpdateJobStateInTransaction  mockUpdateJobStateInTransaction
	CreatePipelineInTransaction  mockCreatePipelineInTransaction
	InspectPipelineInTransaction mockInspectPipelineInTransaction
	ActivateAuthInTransaction    mockActivateAuthInTransaction
}

MockPPSTransactionServer provides a mocking interface for overriding PPS behavior inside transactions.

func NewMockPPSTransactionServer

func NewMockPPSTransactionServer() *MockPPSTransactionServer

NewMockPPSTransactionServer instantiates a MockPPSTransactionServer

type MockPachd

type MockPachd struct {
	Addr net.Addr

	PFS           mockPFSServer
	Storage       mockStorageServer
	PPS           mockPPSServer
	Auth          mockAuthServer
	GetAuthServer func() authserver.APIServer
	Transaction   mockTransactionServer
	Identity      mockIdentityServer
	Enterprise    mockEnterpriseServer
	License       mockLicenseServer
	Version       mockVersionServer
	Admin         mockAdminServer
	Proxy         mockProxyServer
	Logs          mockLogsServer
	Metadata      mockMetadataServer
	// contains filtered or unexported fields
}

MockPachd provides an interface for running the interface for a Pachd API server locally without any of its dependencies. Tests may mock out specific API calls by providing a handler function, and later check information about the mocked calls.

func NewMockPachd

func NewMockPachd(ctx context.Context, port uint16, options ...InterceptorOption) (*MockPachd, error)

NewMockPachd constructs a mock Pachd API server whose behavior can be controlled through the MockPachd instance. By default, all API calls will error, unless a handler is specified. A port value of 0 will choose a free port automatically options can be supplied to configure the grpcutil.Server's interceptors.

func (*MockPachd) Close

func (mock *MockPachd) Close() error

Close will cancel the mock Pachd API server goroutine and return its result

func (*MockPachd) Err

func (mock *MockPachd) Err() <-chan error

Err returns a read-only channel that will receive the first error that occurs in the server group (stopping all the servers).

type RotateRootTokenFunc

type RotateRootTokenFunc func(context.Context, *auth.RotateRootTokenRequest) (*auth.RotateRootTokenResponse, error)