general

Documentation

Index

• Variables
• type Client
• type ClientBuilder
  • func (receiver *ClientBuilder) Build() (Client, error)
  • func (receiver *ClientBuilder) Headers(headers map[string]string) *ClientBuilder
  • func (receiver *ClientBuilder) HostAvailablerConfig(hostAvailablerConfig *core.HostAvailablerConfig) *ClientBuilder
  • func (receiver *ClientBuilder) HostHeader(hostHeader string) *ClientBuilder
  • func (receiver *ClientBuilder) Hosts(hosts []string) *ClientBuilder
  • func (receiver *ClientBuilder) MetricsConfig(metricsConfig *metrics.Config) *ClientBuilder
  • func (receiver *ClientBuilder) Region(region core.Region) *ClientBuilder
  • func (receiver *ClientBuilder) Schema(schema string) *ClientBuilder
  • func (receiver *ClientBuilder) Tenant(tenant string) *ClientBuilder
  • func (receiver *ClientBuilder) TenantId(tenantId string) *ClientBuilder
  • func (receiver *ClientBuilder) Token(token string) *ClientBuilder

Variables

var (
	TooManyItemsErr = errors.New(fmt.Sprintf(errMsgFormat, MaxImportItemCount))
)

Types

type Client

type Client interface {
	common.Client

	// Release
	// release resources
	Release()

	// WriteData
	//
	// Writes at most 100 data at a time. Exceeding 100 in a request results in
	// a rejection. One can use this to upload new data, or update existing
	// data (by providing all the fields, some data type not support update, e.g. user event).
	WriteData(dataList []map[string]interface{}, topic string,
		opts ...option.Option) (*WriteResponse, error)

	// Predict
	//
	// Gets the list of products (ranked).
	// The updated user data will take effect in 24 hours.
	// The updated product data will take effect in 30 mins.
	// Depending how (realtime or batch) the UserEvents are sent back, it will
	// be fed into the models and take effect after that.
	Predict(request *PredictRequest, scene string, opts ...option.Option) (*PredictResponse, error)

	// Callback
	//
	// Sends back the actual product list shown to the users based on the
	// customized changes from `PredictResponse`.
	// example: our Predict call returns the list of items [1, 2, 3, 4].
	// Your custom logic have decided that product 3 has been sold out and
	// product 10 needs to be inserted before 2 based on some promotion rules,
	// the AckServerImpressionsRequest content items should looks like
	// [
	//   {id:1, extra: "{\"reason\": \"kept\"}", pos:1},
	//   {id:10, extra: "{\"reason\": \"inserted\"}", pos:2},
	//   {id:2, extra: "{\"reason\": \"kept\"}", pos:3},
	//   {id:4, extra: "{\"reason\": \"kept\"}", pos:4},
	//   {id:3, extra: "{\"reason\": \"filtered\"}", pos:0},
	// ].
	Callback(request *CallbackRequest, opts ...option.Option) (*CallbackResponse, error)
}

type ClientBuilder

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

func (*ClientBuilder) Build

func (receiver *ClientBuilder) Build() (Client, error)

func (*ClientBuilder) Headers

func (receiver *ClientBuilder) Headers(headers map[string]string) *ClientBuilder

func (*ClientBuilder) HostAvailablerConfig

func (receiver *ClientBuilder) HostAvailablerConfig(hostAvailablerConfig *core.HostAvailablerConfig) *ClientBuilder

func (*ClientBuilder) HostHeader

func (receiver *ClientBuilder) HostHeader(hostHeader string) *ClientBuilder

func (*ClientBuilder) Hosts

func (receiver *ClientBuilder) Hosts(hosts []string) *ClientBuilder

func (*ClientBuilder) MetricsConfig

func (receiver *ClientBuilder) MetricsConfig(metricsConfig *metrics.Config) *ClientBuilder

func (*ClientBuilder) Region

func (receiver *ClientBuilder) Region(region core.Region) *ClientBuilder

func (*ClientBuilder) Schema

func (receiver *ClientBuilder) Schema(schema string) *ClientBuilder

func (*ClientBuilder) Tenant

func (receiver *ClientBuilder) Tenant(tenant string) *ClientBuilder

func (*ClientBuilder) TenantId

func (receiver *ClientBuilder) TenantId(tenantId string) *ClientBuilder

func (*ClientBuilder) Token

func (receiver *ClientBuilder) Token(token string) *ClientBuilder