server

Documentation

Index

• type Starcoder
  • func NewStarcoderServer(flowgraphDir string, perfCtrInterval time.Duration, ...) *Starcoder
  • func (s *Starcoder) Close() error
  • func (s *Starcoder) GetCurrentFlowgraphCount() int
  • func (s *Starcoder) RunFlowgraph(stream pb.Starcoder_RunFlowgraphServer) error

Types

type Starcoder

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

func NewStarcoderServer

func NewStarcoderServer(flowgraphDir string, perfCtrInterval time.Duration, silencedCommandBlocks []string, log *zap.SugaredLogger, metrics *monitoring.Metrics) *Starcoder

func (*Starcoder) Close

func (s *Starcoder) Close() error

func (*Starcoder) GetCurrentFlowgraphCount

func (s *Starcoder) GetCurrentFlowgraphCount() int

func (*Starcoder) RunFlowgraph

func (s *Starcoder) RunFlowgraph(stream pb.Starcoder_RunFlowgraphServer) error