io

Documentation

Index

• type CdCmd
  • func NewCdCmd(dir string) *CdCmd
  • func (c *CdCmd) Get() string
• type Executor
  • func (e *Executor) Execute(name string, args []string) (bytes.Buffer, error)
• type File
  • func (f *File) Read(fileName string) ([]byte, error)
  • func (f *File) Remove(fileName string) error
  • func (f *File) Write(fileName, data string) error
• type FindTopicsCmd
  • func NewFindTopicsCmd(lastWritten int64, dataDir string) *FindTopicsCmd
  • func (f *FindTopicsCmd) Get() string
• type MockExecutor
  • func (m *MockExecutor) Execute(name string, args []string) (bytes.Buffer, error)
• type SignalHandler
  • func (s *SignalHandler) Close()
  • func (s *SignalHandler) SetListener(ctx context.Context, cancelFunc context.CancelFunc, ...)

Types

type CdCmd

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

func NewCdCmd

func NewCdCmd(dir string) *CdCmd

func (*CdCmd) Get

func (c *CdCmd) Get() string

type Executor

type Executor struct{}

func (*Executor) Execute

func (e *Executor) Execute(name string, args []string) (bytes.Buffer, error)

type File

type File struct{}

func (*File) Read

func (f *File) Read(fileName string) ([]byte, error)

func (*File) Remove

func (f *File) Remove(fileName string) error

func (*File) Write

func (f *File) Write(fileName, data string) error

type FindTopicsCmd

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

func NewFindTopicsCmd

func NewFindTopicsCmd(lastWritten int64, dataDir string) *FindTopicsCmd

func (*FindTopicsCmd) Get

func (f *FindTopicsCmd) Get() string

type MockExecutor

type MockExecutor struct {
	mock.Mock
}

func (*MockExecutor) Execute

func (m *MockExecutor) Execute(name string, args []string) (bytes.Buffer, error)

type SignalHandler

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

func (*SignalHandler) Close

func (s *SignalHandler) Close()

Close ensures all the set up listeners have completed execution.

func (*SignalHandler) SetListener

func (s *SignalHandler) SetListener(ctx context.Context, cancelFunc context.CancelFunc, syscallSignal syscall.Signal)

SetListener notifies the context about an external signal that has been notified by cancelling the context.