Documentation
¶
Index ¶
- func DummyEmulator(_ context.Context, dummy *DummyJobOutput)
- type DummyJobOutput
- func (d *DummyJobOutput) AddOutput(_ context.Context, _ []byte, _ actCmd.ProcessOutType)
- func (d *DummyJobOutput) Close()
- func (d *DummyJobOutput) GetExitCode() chan int
- func (d *DummyJobOutput) GetOutputChan() chan actCmd.SingleOutput
- func (d *DummyJobOutput) ProgramError() chan error
- func (d *DummyJobOutput) SetExitCode(_ int)
- type MockStream
- func (m *MockStream) Close()
- func (m *MockStream) Context() context.Context
- func (m *MockStream) RecvMsg(interface{}) error
- func (m *MockStream) Send(msg *actservice.JobLogMessage) error
- func (m *MockStream) SendHeader(_ metadata.MD) error
- func (m *MockStream) SendMsg(interface{}) error
- func (m *MockStream) SetHeader(_ metadata.MD) error
- func (m *MockStream) SetTrailer(_ metadata.MD)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DummyEmulator ¶
func DummyEmulator(_ context.Context, dummy *DummyJobOutput)
Types ¶
type DummyJobOutput ¶
type DummyJobOutput struct {
// contains filtered or unexported fields
}
func SuccessfulDummyJobOutput ¶
func SuccessfulDummyJobOutput() *DummyJobOutput
func (*DummyJobOutput) AddOutput ¶
func (d *DummyJobOutput) AddOutput(_ context.Context, _ []byte, _ actCmd.ProcessOutType)
func (*DummyJobOutput) Close ¶
func (d *DummyJobOutput) Close()
func (*DummyJobOutput) GetExitCode ¶
func (d *DummyJobOutput) GetExitCode() chan int
func (*DummyJobOutput) GetOutputChan ¶
func (d *DummyJobOutput) GetOutputChan() chan actCmd.SingleOutput
func (*DummyJobOutput) ProgramError ¶
func (d *DummyJobOutput) ProgramError() chan error
func (*DummyJobOutput) SetExitCode ¶
func (d *DummyJobOutput) SetExitCode(_ int)
type MockStream ¶
type MockStream struct {
// contains filtered or unexported fields
}
grpc stream mocker
func NewMockStream ¶
func NewMockStream() *MockStream
func (*MockStream) Close ¶
func (m *MockStream) Close()
func (*MockStream) Context ¶
func (m *MockStream) Context() context.Context
func (*MockStream) RecvMsg ¶
func (m *MockStream) RecvMsg(interface{}) error
func (*MockStream) Send ¶
func (m *MockStream) Send(msg *actservice.JobLogMessage) error
func (*MockStream) SendHeader ¶
func (m *MockStream) SendHeader(_ metadata.MD) error
func (*MockStream) SendMsg ¶
func (m *MockStream) SendMsg(interface{}) error
func (*MockStream) SetTrailer ¶
func (m *MockStream) SetTrailer(_ metadata.MD)
Source Files
Click to show internal directories.
Click to hide internal directories.