cli

Documentation

Index

• Constants
• func NewTypedAPIResponse[TBody any](body TBody) func(resp *http.Response, err error) *TypedAPIResponse[TBody]
• type APIClient
  • func NewApiClient(apiAddress string) *APIClient
  • func (api *APIClient) CallAction(job, action string) APIResponse
  • func (api *APIClient) JobList() TypedAPIResponse[[]string]
  • func (api *APIClient) JobLogs(job string, follow bool, tailLen int) APIResponse
  • func (api *APIClient) JobRestart(job string) APIResponse
  • func (api *APIClient) JobStart(job string) APIResponse
  • func (api *APIClient) JobStatus(job string) TypedAPIResponse[proc.CommonJobStatus]
  • func (api *APIClient) JobStop(job string) APIResponse
• type APIResponse
  • func NewAPIResponse(resp *http.Response, err error) APIResponse
  • func NewStreamingAPIResponse(url *url.URL, dialer *websocket.Dialer, ...) APIResponse
• type CommonAPIResponse
  • func (resp *CommonAPIResponse) Err() error
  • func (resp *CommonAPIResponse) Print() error
• type StreamingAPIResponse
  • func (resp *StreamingAPIResponse) Err() error
  • func (resp *StreamingAPIResponse) Print() error
• type StreamingAPIResponseHandler
• type TypedAPIResponse
  • func (resp *TypedAPIResponse[TBody]) Err() error
  • func (resp *TypedAPIResponse[TBody]) Print() error

Constants

const (
	ApiActionJobStart   = "start"
	ApiActionJobRestart = "restart"
	ApiActionJobStop    = "stop"
	ApiActionJobStatus  = "status"
	ApiActionJobLogs    = "logs"
)

Functions

func NewTypedAPIResponse

func NewTypedAPIResponse[TBody any](body TBody) func(resp *http.Response, err error) *TypedAPIResponse[TBody]

Types

type APIClient

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

func NewApiClient

func NewApiClient(apiAddress string) *APIClient

func (*APIClient) CallAction

func (api *APIClient) CallAction(job, action string) APIResponse

func (*APIClient) JobList

func (api *APIClient) JobList() TypedAPIResponse[[]string]

func (*APIClient) JobLogs

func (api *APIClient) JobLogs(job string, follow bool, tailLen int) APIResponse

func (*APIClient) JobRestart

func (api *APIClient) JobRestart(job string) APIResponse

func (*APIClient) JobStart

func (api *APIClient) JobStart(job string) APIResponse

func (*APIClient) JobStatus

func (api *APIClient) JobStatus(job string) TypedAPIResponse[proc.CommonJobStatus]

func (*APIClient) JobStop

func (api *APIClient) JobStop(job string) APIResponse

type APIResponse

type APIResponse interface {
	Print() error
	Err() error
}

func NewAPIResponse

func NewAPIResponse(resp *http.Response, err error) APIResponse

func NewStreamingAPIResponse

func NewStreamingAPIResponse(url *url.URL, dialer *websocket.Dialer, streamingFunc StreamingAPIResponseHandler) APIResponse

type CommonAPIResponse

type CommonAPIResponse struct {
	StatusCode int    `json:"statusCode"`
	Body       string `json:"body"`
	Error      error  `json:"error"`
	// contains filtered or unexported fields
}

func (*CommonAPIResponse) Err

func (resp *CommonAPIResponse) Err() error

func (*CommonAPIResponse) Print

func (resp *CommonAPIResponse) Print() error

type StreamingAPIResponse

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

func (*StreamingAPIResponse) Err

func (resp *StreamingAPIResponse) Err() error

func (*StreamingAPIResponse) Print

func (resp *StreamingAPIResponse) Print() error

type StreamingAPIResponseHandler

type StreamingAPIResponseHandler func(ctx context.Context, conn *websocket.Conn, msg chan []byte, err chan error)

type TypedAPIResponse

type TypedAPIResponse[TBody any] struct {
	StatusCode int   `json:"statusCode"`
	Body       TBody `json:"body"`
	Error      error `json:"error"`
	// contains filtered or unexported fields
}

func (*TypedAPIResponse[TBody]) Err

func (resp *TypedAPIResponse[TBody]) Err() error

func (*TypedAPIResponse[TBody]) Print

func (resp *TypedAPIResponse[TBody]) Print() error