Function newSlaveNode

pkg/cluster/node.go:238–251

(ctx context.Context, model *ent.Node, config conf.ConfigProvider, settings setting.Provider)

}

func newSlaveNode(ctx context.Context, model *ent.Node, config conf.ConfigProvider, settings setting.Provider) *slaveNode {
	siteBasic := settings.SiteBasic(ctx)
	return &slaveNode{
		nodeBase: nodeBase{
			model: model,
		},
		client: request.NewClient(config,
			request.WithCorrelationID(),
			request.WithSlaveMeta(model.ID),
			request.WithMasterMeta(siteBasic.ID, settings.SiteURL(setting.UseFirstSiteUrl(ctx)).String()),
			request.WithCredential(auth.HMACAuth{[]byte(model.SlaveKey)}, int64(settings.SlaveRequestSignTTL(ctx))),
			request.WithEndpoint(model.Server)),
	}
}

func (n *slaveNode) CreateTask(ctx context.Context, taskType string, state string) (int, error) {
	reqBody, err := json.Marshal(&CreateSlaveTask{