http

Documentation

Index

• type PipelineStreamDumpper
  • func NewPipelineStreamDumpper(stream pipeline.Service_WatchPipelineClient) *PipelineStreamDumpper
  • func (d *PipelineStreamDumpper) Close() error
  • func (d *PipelineStreamDumpper) Read(buf []byte) (n int, err error)
  • func (d *PipelineStreamDumpper) Write(buf []byte) (n int, err error)
• type Proxy
  • func NewProxy() *Proxy
  • func (p *Proxy) Proxy(ctx context.Context, conn *websocket.Conn, stream io.ReadWriter)
• type ValueTypeDesc

Types

type PipelineStreamDumpper

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

func NewPipelineStreamDumpper

func NewPipelineStreamDumpper(stream pipeline.Service_WatchPipelineClient) *PipelineStreamDumpper

func (*PipelineStreamDumpper) Close

func (d *PipelineStreamDumpper) Close() error

func (*PipelineStreamDumpper) Read

func (d *PipelineStreamDumpper) Read(buf []byte) (n int, err error)

func (*PipelineStreamDumpper) Write

func (d *PipelineStreamDumpper) Write(buf []byte) (n int, err error)

type Proxy

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

func NewProxy

func NewProxy() *Proxy

func (*Proxy) Proxy

func (p *Proxy) Proxy(ctx context.Context, conn *websocket.Conn, stream io.ReadWriter)

type ValueTypeDesc

type ValueTypeDesc struct {
	Type   pipeline.PARAM_VALUE_TYPE `json:"type"`
	Prefix string                    `json:"prefix"`
	Name   string                    `json:"name"`
	Desc   string                    `json:"desc"`
	Value  string                    `json:"value"`
	IsEdit bool                      `json:"is_edit"`
}