cloudeventpb

type CloudEventMethodOptions struct {

	// subject name is same with config jobs consumers
	// subject name sametime is topic name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// cloud event operation
	Operation *string `protobuf:"bytes,2,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type CloudEventServiceOptions struct {

	// job event name is same with config jobs consumers job name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type PushEventOptions struct {

	// The content type for the data (optional).
	// If not set, the default content type is "application/json".
	ContentType *string `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3,oneof" json:"content_type,omitempty"`
	// The metadata passing to pub components
	// metadata property:
	// - key : the key of the message.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The delay duration of the message.
	Delay *durationpb.Duration `protobuf:"bytes,3,opt,name=delay,proto3,oneof" json:"delay,omitempty"`
	// The message id
	// If not set, the default message id is uuid.
	// If set, the message id must be unique.
	MsgId *string `protobuf:"bytes,4,opt,name=msg_id,json=msgId,proto3,oneof" json:"msg_id,omitempty"`
	// The sender of the message.
	Sender *string `protobuf:"bytes,5,opt,name=sender,proto3,oneof" json:"sender,omitempty"`
	// contains filtered or unexported fields
}

type RegisterJobOptions struct {
	JobName *string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3,oneof" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}