pb

type AddReq struct {
	// @inject_tag: valid:"required" 业务名称(worker回调时会返回)
	Name string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" valid:"required"`
	Time *ExecTime `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// @inject_tag: valid:"required" 回调路径
	Callback *CallbackInfo `protobuf:"bytes,3,opt,name=callback,proto3" json:"callback,omitempty" valid:"required"`
	// 返回参数(worker回调时返回，尽量传输小数据，如果有需要自行存储在业务，与uid做绑定)
	Args                 string   `protobuf:"bytes,4,opt,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type AddResp struct {
	// @inject_tag: valid:"required" 返回当前唯一标识
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty" valid:"required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type CallBackReq struct {
	// @inject_tag: valid:"required"
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty" valid:"required"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url                  string   `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Args                 string   `protobuf:"bytes,4,opt,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type CallbackClient interface {
	Send(ctx context.Context, in *CallBackReq, opts ...grpc.CallOption) (*empty.Empty, error)
}

type CallbackInfo struct {
	// @inject_tag: valid:"required" 协议(HTTP\GRPC)
	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty" valid:"required"`
	// @inject_tag: valid:"required" 地址+端口
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" valid:"required"`
	// 路径(GRPC回调函数固定的)
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type CallbackServer interface {
	Send(context.Context, *CallBackReq) (*empty.Empty, error)
}

type DelayQueueClient interface {
	Add(ctx context.Context, in *AddReq, opts ...grpc.CallOption) (*AddResp, error)
	Get(ctx context.Context, in *RetrieveReq, opts ...grpc.CallOption) (*Task, error)
	Remove(ctx context.Context, in *RemoveReq, opts ...grpc.CallOption) (*empty.Empty, error)
}

type DelayQueueServer interface {
	Add(context.Context, *AddReq) (*AddResp, error)
	Get(context.Context, *RetrieveReq) (*Task, error)
	Remove(context.Context, *RemoveReq) (*empty.Empty, error)
}

type ExecTime struct {
	// 执行时间戳
	Duration int64 `protobuf:"varint,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// 是否是相对时间(如果是相对时间，那么真正执行时间为NOW()+duration)
	Relative             bool     `protobuf:"varint,2,opt,name=relative,proto3" json:"relative,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RemoveReq struct {
	// @inject_tag: valid:"required"
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty" valid:"required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RetrieveReq struct {
	// @inject_tag: valid:"required"
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty" valid:"required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Task struct {
	Id                   uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Uid                  string   `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Type                 TaskType `protobuf:"varint,4,opt,name=type,proto3,enum=pb.TaskType" json:"type,omitempty"`
	Times                int32    `protobuf:"varint,5,opt,name=times,proto3" json:"times,omitempty"`
	RetryTimes           int32    `protobuf:"varint,6,opt,name=retry_times,json=retryTimes,proto3" json:"retry_times,omitempty"`
	ExecTime             int64    `protobuf:"varint,7,opt,name=exec_time,json=execTime,proto3" json:"exec_time,omitempty"`
	NextExecTime         int64    `protobuf:"varint,8,opt,name=next_exec_time,json=nextExecTime,proto3" json:"next_exec_time,omitempty"`
	Schema               string   `protobuf:"bytes,9,opt,name=schema,proto3" json:"schema,omitempty"`
	Address              string   `protobuf:"bytes,10,opt,name=address,proto3" json:"address,omitempty"`
	Path                 string   `protobuf:"bytes,11,opt,name=path,proto3" json:"path,omitempty"`
	CreatedAt            int64    `protobuf:"varint,12,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            int64    `protobuf:"varint,13,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type TaskType int32

type UnimplementedCallbackServer struct {
}

type UnimplementedDelayQueueServer struct {
}