core

Documentation

Index

• Constants
• func AllPlugins() map[string]Plugin
• func FindPluginNameBySubPkgPath(subPkgPath string) (string, error)
• func RegisterPlugin(name string, plugin Plugin) error
• func UnmarshalResponse(res *http.Response, v interface{}) error
• type ApiClient
  • func NewApiClient(endpoint string, headers map[string]string, timeout time.Duration, ...) *ApiClient
  • func (apiClient *ApiClient) Do(method string, path string, query *url.Values, body *map[string]interface{}, ...) (*http.Response, error)
  • func (apiClient *ApiClient) Get(path string, query *url.Values, headers *map[string]string) (*http.Response, error)
  • func (apiClient *ApiClient) SetEndpoint(endpoint string)
  • func (apiClient *ApiClient) SetHeaders(headers map[string]string)
  • func (ApiClient *ApiClient) SetMaxRetry(maxRetry int)
  • func (apiClient *ApiClient) SetProxy(proxyUrl string) error
  • func (ApiClient *ApiClient) SetTimeout(timeout time.Duration)
  • func (apiClient *ApiClient) Setup(endpoint string, headers map[string]string, timeout time.Duration, ...)
• type ApiClientAfterResponse
• type ApiClientBeforeRequest
• type ApiResourceHandler
• type ApiResourceInput
• type ApiResourceOutput
• type Iso8601Time
  • func (jt Iso8601Time) MarshalJSON() ([]byte, error)
  • func (jt *Iso8601Time) String() string
  • func (jt *Iso8601Time) ToTime() time.Time
  • func (jt *Iso8601Time) UnmarshalJSON(b []byte) error
• type Plugin
  • func GetPlugin(name string) (Plugin, error)

Constants

const ISO_8601_FORMAT = "2006-01-02T15:04:05-0700"

Functions

func AllPlugins

func AllPlugins() map[string]Plugin

func FindPluginNameBySubPkgPath

func FindPluginNameBySubPkgPath(subPkgPath string) (string, error)

func RegisterPlugin

func RegisterPlugin(name string, plugin Plugin) error

func UnmarshalResponse

func UnmarshalResponse(res *http.Response, v interface{}) error

Types

type ApiClient

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

func NewApiClient

func NewApiClient(
	endpoint string,
	headers map[string]string,
	timeout time.Duration,
	maxRetry int,
) *ApiClient

func (*ApiClient) Do

func (apiClient *ApiClient) Do(
	method string,
	path string,
	query *url.Values,
	body *map[string]interface{},
	headers *map[string]string,
) (*http.Response, error)

func (*ApiClient) Get

func (apiClient *ApiClient) Get(
	path string,
	query *url.Values,
	headers *map[string]string,
) (*http.Response, error)

func (*ApiClient) SetEndpoint

func (apiClient *ApiClient) SetEndpoint(endpoint string)

func (*ApiClient) SetHeaders

func (apiClient *ApiClient) SetHeaders(headers map[string]string)

func (*ApiClient) SetMaxRetry

func (ApiClient *ApiClient) SetMaxRetry(maxRetry int)

func (*ApiClient) SetProxy

func (apiClient *ApiClient) SetProxy(proxyUrl string) error

func (*ApiClient) SetTimeout

func (ApiClient *ApiClient) SetTimeout(timeout time.Duration)

func (*ApiClient) Setup

func (apiClient *ApiClient) Setup(
	endpoint string,
	headers map[string]string,
	timeout time.Duration,
	maxRetry int,
)

type ApiClientAfterResponse

type ApiClientAfterResponse func(res *http.Response) error

type ApiClientBeforeRequest

type ApiClientBeforeRequest func(req *http.Request) error

type ApiResourceHandler

type ApiResourceHandler func(input *ApiResourceInput) (*ApiResourceOutput, error)

type ApiResourceInput

type ApiResourceInput struct {
	Params map[string]string      // path variables
	Query  url.Values             // query string
	Body   map[string]interface{} // json body
}

type ApiResourceOutput

type ApiResourceOutput struct {
	Body interface{} // response body
}

type Iso8601Time

type Iso8601Time time.Time

parse iso8601 datetime format for json.Unmarshal

declare your field type as:

type Foo struct {
	Created Iso8601Time
}

foo := &Foo{} err := json.Unmarshal("{\"created\": \"2021-02-19T01:53:35.340+0800\"}", foo) var time time.Time time = foo.Created.ToTime()

func (Iso8601Time) MarshalJSON

func (jt Iso8601Time) MarshalJSON() ([]byte, error)

func (*Iso8601Time) String

func (jt *Iso8601Time) String() string

func (*Iso8601Time) ToTime

func (jt *Iso8601Time) ToTime() time.Time

func (*Iso8601Time) UnmarshalJSON

func (jt *Iso8601Time) UnmarshalJSON(b []byte) error

type Plugin

type Plugin interface {
	Description() string
	Init()
	Execute(options map[string]interface{}, progress chan<- float32, ctx context.Context)
	// PkgPath information lost when compiled as plugin(.so)
	RootPkgPath() string
	ApiResources() map[string]map[string]ApiResourceHandler
}

func GetPlugin

func GetPlugin(name string) (Plugin, error)