client

Documentation

Index

• type ClientHandler
  • func (h *ClientHandler) Execute(ctx context.Context, nickname string, namespaces []string, cmd *message.Cmd, ...)
  • func (h *ClientHandler) GetNickname(nickname string, cmd *message.Cmd, resp chan<- *message.Msg)
  • func (h *ClientHandler) GetRunMetadata(ctx context.Context, cmd *message.Cmd, resp chan<- *message.Msg)
  • func (h *ClientHandler) ListResourceRuns(ctx context.Context, cmd *message.Cmd, resp chan<- *message.Msg)
  • func (h *ClientHandler) ListStreams(namespaces []string, cmd *message.Cmd, resp chan<- *message.Msg)
  • func (h *ClientHandler) PlayRun(namespaces []string, ctx context.Context, cmd *message.Cmd, ...)
  • func (h *ClientHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (h *ClientHandler) StreamCmd(namespaces []string, cmd *message.Cmd)
  • func (h *ClientHandler) StreamSub(namespaces []string, cmd *message.Cmd, sub *redis.PubSub, ...)
  • func (h *ClientHandler) StreamUnsub(namespaces []string, cmd *message.Cmd, sub *redis.PubSub, ...)

Types

type ClientHandler

type ClientHandler struct {
	Redis  *redis.Client
	Addr   string
	MaxNPR float64
	Srv    *http.Server

	websocket.Upgrader
}

func (*ClientHandler) Execute

func (h *ClientHandler) Execute(
	ctx context.Context,
	nickname string,
	namespaces []string,
	cmd *message.Cmd,
	resp chan<- *message.Msg,
	sub *redis.PubSub,
)

func (*ClientHandler) GetNickname

func (h *ClientHandler) GetNickname(nickname string, cmd *message.Cmd, resp chan<- *message.Msg)

func (*ClientHandler) GetRunMetadata

func (h *ClientHandler) GetRunMetadata(ctx context.Context, cmd *message.Cmd, resp chan<- *message.Msg)

func (*ClientHandler) ListResourceRuns

func (h *ClientHandler) ListResourceRuns(ctx context.Context, cmd *message.Cmd, resp chan<- *message.Msg)

func (*ClientHandler) ListStreams

func (h *ClientHandler) ListStreams(namespaces []string, cmd *message.Cmd, resp chan<- *message.Msg)

func (*ClientHandler) PlayRun

func (h *ClientHandler) PlayRun(namespaces []string, ctx context.Context, cmd *message.Cmd, resp chan<- *message.Msg)

func (*ClientHandler) ServeHTTP

func (h *ClientHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*ClientHandler) StreamCmd

func (h *ClientHandler) StreamCmd(namespaces []string, cmd *message.Cmd)

func (*ClientHandler) StreamSub

func (h *ClientHandler) StreamSub(namespaces []string, cmd *message.Cmd, sub *redis.PubSub, resp chan<- *message.Msg)

func (*ClientHandler) StreamUnsub

func (h *ClientHandler) StreamUnsub(namespaces []string, cmd *message.Cmd, sub *redis.PubSub, resp chan<- *message.Msg)