provider

README

对资源提供商，通过API获取资源，并转换为标准的接口数据(Resource)

Documentation

Index

• type HostHandler
• type HostProvider
• type QueryHostRequest
  • func NewQueryHostRequet() *QueryHostRequest

Types

type HostHandler

type HostHandler func(*resource.Resource)

http.Handler

type HostProvider

type HostProvider interface {
	// 获取Host 主机接口，数据是分页批量拉取，我们的接口是 单独一个一个创建资源的
	// resp = QueryHost()
	// for resp { CreateResource(item) }
	// 拉取一页数据： 10s, 一个一个往数据库里面写，这样是最基本的接口设计
	// 如果有一万条数据，会非常耗内存空间，回调函数就不会有这个问题，查出来一条处理一条
	// QueryHost(context.Context, *QueryHostRequest) (*resource.ResourceSet, error)
	// 类比 Js ForEach, 给一个回调函数
	// QueryHost() {for resources; fn(item)}
	// 通过回调把接口返回出去, 流式处理Stream
	QueryHost(context.Context, *QueryHostRequest, HostHandler) error
}

客户端封装

type QueryHostRequest

type QueryHostRequest struct {
}

func NewQueryHostRequet

func NewQueryHostRequet() *QueryHostRequest