watch

Documentation

Index

• type ProcessFactory
  • func NewProcessFactory(conn *grpc.ClientConn) *ProcessFactory
  • func (p ProcessFactory) SendCommand(i int64) error
  • func (p ProcessFactory) Stream(cat string) <-chan render.Rows
  • func (p ProcessFactory) Terminate()

Types

type ProcessFactory

type ProcessFactory struct {
	serialize.Serializable
	// contains filtered or unexported fields
}

func NewProcessFactory

func NewProcessFactory(conn *grpc.ClientConn) *ProcessFactory

func (ProcessFactory) SendCommand

func (p ProcessFactory) SendCommand(i int64) error

func (ProcessFactory) Stream

func (p ProcessFactory) Stream(cat string) <-chan render.Rows

func (ProcessFactory) Terminate

func (p ProcessFactory) Terminate()