serve

Documentation

Index

• func CustomJSONHandlerFunc(h health.IHealth, custom map[string]interface{}) http.HandlerFunc
• func GetJsonRpcHandler() *jsonrpc.MethodRepository
• func InitLogrus(out io.Writer, level log.Level)
• func JSONRPCUnmarshal(params []byte, dst interface{}) *jsonrpc.Error
• func Serve(BL *bl.BL, address string, port int64, healthPort int64)
• type CreateRunHandler
  • func (h CreateRunHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type DeleteRunsHandler
  • func (h DeleteRunsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type DoStepByLabelHandler
  • func (h DoStepByLabelHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type DoStepByUUIDHandler
  • func (h DoStepByUUIDHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type GetRunsHandler
  • func (h GetRunsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type GetStepsHandler
  • func (h GetStepsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type ListRunsHandler
  • func (h ListRunsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type ListStepsHandler
  • func (h ListStepsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type UpdateRunHandler
  • func (h UpdateRunHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type UpdateStepByLabelHandler
  • func (h UpdateStepByLabelHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)
• type UpdateStepByUUIDHandler
  • func (h UpdateStepByUUIDHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

Functions

func CustomJSONHandlerFunc

func CustomJSONHandlerFunc(h health.IHealth, custom map[string]interface{}) http.HandlerFunc

func GetJsonRpcHandler

func GetJsonRpcHandler() *jsonrpc.MethodRepository

func InitLogrus

func InitLogrus(out io.Writer, level log.Level)

func JSONRPCUnmarshal

func JSONRPCUnmarshal(params []byte, dst interface{}) *jsonrpc.Error

func Serve

func Serve(BL *bl.BL, address string, port int64, healthPort int64)

Types

type CreateRunHandler

type CreateRunHandler struct{}

func (CreateRunHandler) ServeJSONRPC

func (h CreateRunHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type DeleteRunsHandler

type DeleteRunsHandler struct{}

func (DeleteRunsHandler) ServeJSONRPC

func (h DeleteRunsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type DoStepByLabelHandler

type DoStepByLabelHandler struct{}

func (DoStepByLabelHandler) ServeJSONRPC

func (h DoStepByLabelHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type DoStepByUUIDHandler

type DoStepByUUIDHandler struct{}

func (DoStepByUUIDHandler) ServeJSONRPC

func (h DoStepByUUIDHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type GetRunsHandler

type GetRunsHandler struct{}

func (GetRunsHandler) ServeJSONRPC

func (h GetRunsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type GetStepsHandler

type GetStepsHandler struct{}

func (GetStepsHandler) ServeJSONRPC

func (h GetStepsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type ListRunsHandler

type ListRunsHandler struct{}

func (ListRunsHandler) ServeJSONRPC

func (h ListRunsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type ListStepsHandler

type ListStepsHandler struct{}

func (ListStepsHandler) ServeJSONRPC

func (h ListStepsHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type UpdateRunHandler

type UpdateRunHandler struct{}

func (UpdateRunHandler) ServeJSONRPC

func (h UpdateRunHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type UpdateStepByLabelHandler

type UpdateStepByLabelHandler struct{}

func (UpdateStepByLabelHandler) ServeJSONRPC

func (h UpdateStepByLabelHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)

type UpdateStepByUUIDHandler

type UpdateStepByUUIDHandler struct{}

func (UpdateStepByUUIDHandler) ServeJSONRPC

func (h UpdateStepByUUIDHandler) ServeJSONRPC(ctx context.Context, params *fastjson.RawMessage) (interface{}, *jsonrpc.Error)