Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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 ¶
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)
type MockPPSJobStopper ¶
type MockPPSJobStopper struct{}
func (*MockPPSJobStopper) StopJob ¶ added in v2.8.0
func (mpp *MockPPSJobStopper) StopJob(*pfs.Commit)
func (*MockPPSJobStopper) StopJobSet ¶ added in v2.8.0
func (mpp *MockPPSJobStopper) StopJobSet(*pfs.CommitSet)
type MockPPSPropagater ¶
type MockPPSPropagater struct{}
func (*MockPPSPropagater) PropagateJobs ¶
func (mpp *MockPPSPropagater) PropagateJobs()
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
PPS mockPPSServer
Auth mockAuthServer
GetAuthServer func() authserver.APIServer
Transaction mockTransactionServer
Identity mockIdentityServer
Enterprise mockEnterpriseServer
License mockLicenseServer
Version mockVersionServer
Admin mockAdminServer
Proxy mockProxyServer
// 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.
type RotateRootTokenFunc ¶
type RotateRootTokenFunc func(context.Context, *auth.RotateRootTokenRequest) (*auth.RotateRootTokenResponse, error)
Source Files
Directories