公开(公告)号：US20210160185A1

公开(公告)日：2021-05-27

申请号：US17149563

申请日：2021-01-14

Applicant: eBay Inc.

Inventor： Sharad R. Murthy ,  Bhaven Avalani ,  Hongyue Nemo Chen ,  Tony Chung Tung Ng ,  Weiwei Jin ,  Xinglang Wang ,  Mingming Wang ,  Wei Fang

IPC: H04L12/801 ,  G06F15/17 ,  H04L29/08 ,  G06F15/16 ,  G06Q10/10 ,  G06Q20/32 ,  G06Q30/00 ,  H04L29/06 ,  H04L12/835

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. A subscription interface receives data indicative of a subscription request for sessionized data. An allocation module allocates a sessionizer bank linked to the subscription request. A messaging interface module provisions identifiers linked to the respective processing engines of the sessionizer bank. The messaging interface module registers the allocated sessionizer bank as available to process event messages matching the subscription request by providing the provisioned identifiers. The messaging interface module receives event messages from a producer device linked by a collection server to a selected one of the processing engines of the sessionizer bank. The selected one of the processing engine processes the received event messages in accordance with session rule data linked to the subscription request to generate sessionized data.

公开(公告)号：US20240031294A1

公开(公告)日：2024-01-25

申请号：US18475083

申请日：2023-09-26

Applicant: eBay Inc.

Inventor： Sharad R. MURTHY ,  Bhaven Avalani ,  Hongyue Nemo Chen ,  Tony Chung Tung Ng ,  Weiwei Jin ,  Xinglang Wang ,  Mingming Wang ,  Wei Fang

IPC: H04L47/10 ,  G06F15/17 ,  H04L67/10 ,  G06F15/16 ,  G06Q10/101 ,  G06Q30/016 ,  G06Q20/32 ,  H04L67/55 ,  H04L67/563 ,  H04L47/19 ,  H04L47/30

CPC classification number: H04L47/15 ,  G06F15/17 ,  H04L67/10 ,  G06F15/16 ,  G06Q10/101 ,  G06Q30/016 ,  G06Q20/326 ,  H04L67/55 ,  H04L67/563 ,  H04L47/19 ,  H04L47/30

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. A subscription interface receives data indicative of a subscription request for sessionized data. An allocation module allocates a sessionizer bank linked to the subscription request. A messaging interface module provisions identifiers linked to the respective processing engines of the sessionizer bank. The messaging interface module registers the allocated sessionizer bank as available to process event messages matching the subscription request by providing the provisioned identifiers. The messaging interface module receives event messages from a producer device linked by a collection server to a selected one of the processing engines of the sessionizer bank. The selected one of the processing engine processes the received event messages in accordance with session rule data linked to the subscription request to generate sessionized data.

公开(公告)号：US20190394133A1

公开(公告)日：2019-12-26

申请号：US16545642

申请日：2019-08-20

Applicant: eBay Inc.

Inventor： Sharad R. Murthy ,  Bhaven Avalani ,  Hongyue Nemo Chen ,  Tony Chung Tung Ng ,  Weiwei Jin ,  Xinglang Wang ,  Mingming Wang ,  Wei Fang

IPC: H04L12/801 ,  G06F15/17 ,  H04L29/08 ,  G06F15/16 ,  G06Q10/10 ,  G06Q20/32 ,  G06Q30/00 ,  H04L12/835

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. A subscription interface receives data indicative of a subscription request for sessionized data. An allocation module allocates a sessionizer bank linked to the subscription request. A messaging interface module provisions identifiers linked to the respective processing engines of the sessionizer bank. The messaging interface module registers the allocated sessionizer bank as available to process event messages matching the subscription request by providing the provisioned identifiers. The messaging interface module receives event messages from a producer device linked by a collection server to a selected one of the processing engines of the sessionizer bank. The selected one of the processing engine processes the received event messages in accordance with session rule data linked to the subscription request to generate sessionized data.

公开(公告)号：US10425341B2

公开(公告)日：2019-09-24

申请号：US14901395

申请日：2015-01-23

Applicant: eBay Inc.

Inventor： Sharad R. Murthy ,  Bhaven Avalani ,  Hongyue Nemo Chen ,  Tony Chung Tung Ng ,  Weiwei Jin ,  Xinglang Wang ,  Mingming Wang ,  Wei Fang

IPC: H04L29/08 ,  G06F15/16 ,  H04L12/801 ,  G06F15/17 ,  G06Q10/10 ,  G06Q20/32 ,  G06Q30/00 ,  H04L12/835

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. A subscription interface receives data indicative of a subscription request for sessionized data. An allocation module allocates a sessionizer bank linked to the subscription request. A messaging interface module provisions identifiers linked to the respective processing engines of the sessionizer bank. The messaging interface module registers the allocated sessionizer bank as available to process event messages matching the subscription request by providing the provisioned identifiers. The messaging interface module receives event messages from a producer device linked by a collection server to a selected one of the processing engines of the sessionizer bank. The selected one of the processing engine processes the received event messages in accordance with session rule data linked to the subscription request to generate sessionized data.

公开(公告)号：US20180159731A1

公开(公告)日：2018-06-07

申请号：US14901376

申请日：2015-01-23

Applicant: eBay Inc.

Inventor： Sharad R. Murthy ,  Xinglang Wang ,  Rajeshwari Muthupandian

IPC: H04L12/24 ,  H04L29/06 ,  H04L29/12 ,  H04L12/26

CPC classification number: H04L41/0806 ,  H04L12/1859 ,  H04L41/5003 ,  H04L43/0805 ,  H04L61/2007 ,  H04L69/16

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. An identification module receives first data identifying consumer devices available to receive event messages linked to a topic. The identification module receives second data identifying a producer device available to provide event messages linked to the topic. A provisioning module links a plurality of values to respective consumer devices that are linked to the topic. A scheduler module accesses a first data message linked to the topic. The first data message includes a key value. The scheduler module provides the first data message to a selected one of the consumer devices based on a comparison of the key value and the plurality of values of the respective consumer devices.

公开(公告)号：US11916727B2

公开(公告)日：2024-02-27

申请号：US14901376

申请日：2015-01-23

Applicant: eBay Inc.

Inventor： Sharad R. Murthy ,  Xinglang Wang ,  Rajeshwari Muthupandian

IPC: H04L41/0806 ,  G06F16/2455 ,  H04L12/18 ,  H04L41/5003 ,  H04L43/0805 ,  H04L47/52 ,  H04L49/90 ,  H04L61/5007 ,  H04L69/16

CPC classification number: H04L41/0806 ,  G06F16/24558 ,  H04L12/1859 ,  H04L41/5003 ,  H04L43/0805 ,  H04L47/522 ,  H04L49/90 ,  H04L61/5007 ,  H04L69/16

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. An identification module receives first data identifying consumer devices available to receive event messages linked to a topic. The identification module receives second data identifying a producer device available to provide event messages linked to the topic. A provisioning module links a plurality of values to respective consumer devices that are linked to the topic. A scheduler module accesses a first data message linked to the topic. The first data message includes a key value. The scheduler module provides the first data message to a selected one of the consumer devices based on a comparison of the key value and the plurality of values of the respective consumer devices.

公开(公告)号：US11874821B2

公开(公告)日：2024-01-16

申请号：US17559783

申请日：2021-12-22

Applicant: eBay Inc.

Inventor： Jun Li ,  Mohammad Roohitavaf ,  Xinglang Wang

IPC: G06F16/23 ,  G06F16/215 ,  G06F16/2455 ,  G06F16/25

CPC classification number: G06F16/2365

Abstract: The approaches presented herein may include loading a plurality of metadata instances for a plurality of data blocks stored in a database, each metadata instance of the plurality of metadata instances indicating a respective data block structure applied to aggregate a set of data messages. The approaches may include processing a first metadata instance corresponding to a first set of one or more data blocks of the plurality of data blocks and a second metadata instance corresponding to a second set of one or more data blocks of the plurality of data blocks to perform an anomaly storage check between the first set of one or more data blocks of the plurality of data blocks and the second set of one or more data blocks of the plurality of data blocks. The approaches may include generating an output based at least in part on the anomaly storage check.

公开(公告)号：US11818049B2

公开(公告)日：2023-11-14

申请号：US17149563

申请日：2021-01-14

Applicant: eBay Inc.

Inventor： Sharad R. Murthy ,  Bhaven Avalani ,  Hongyue Nemo Chen ,  Tony Chung Tung Ng ,  Weiwei Jin ,  Xinglang Wang ,  Mingming Wang ,  Wei Fang

IPC: H04L67/55 ,  H04L67/563 ,  H04L47/10 ,  H04L47/19 ,  H04L47/30 ,  G06F15/17 ,  H04L67/10 ,  G06F15/16 ,  G06Q10/101 ,  G06Q30/016 ,  G06Q20/32

CPC classification number: H04L47/15 ,  G06F15/16 ,  G06F15/17 ,  G06Q10/101 ,  G06Q20/326 ,  G06Q30/016 ,  H04L47/19 ,  H04L47/30 ,  H04L67/10 ,  H04L67/55 ,  H04L67/563

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. A subscription interface receives data indicative of a subscription request for sessionized data. An allocation module allocates a sessionizer bank linked to the subscription request. A messaging interface module provisions identifiers linked to the respective processing engines of the sessionizer bank. The messaging interface module registers the allocated sessionizer bank as available to process event messages matching the subscription request by providing the provisioned identifiers. The messaging interface module receives event messages from a producer device linked by a collection server to a selected one of the processing engines of the sessionizer bank. The selected one of the processing engine processes the received event messages in accordance with session rule data linked to the subscription request to generate sessionized data.

公开(公告)号：US20230195714A1

公开(公告)日：2023-06-22

申请号：US17559783

申请日：2021-12-22

Applicant: eBay Inc.

Inventor： Jun Li ,  Mohammad Roohitavaf ,  Xinglang Wang

IPC: G06F16/23

CPC classification number: G06F16/2365

Abstract: The approaches presented herein may include loading a plurality of metadata instances for a plurality of data blocks stored in a database, each metadata instance of the plurality of metadata instances indicating a respective data block structure applied to aggregate a set of data messages. The approaches may include processing a first metadata instance corresponding to a first set of one or more data blocks of the plurality of data blocks and a second metadata instance corresponding to a second set of one or more data blocks of the plurality of data blocks to perform an anomaly storage check between the first set of one or more data blocks of the plurality of data blocks and the second set of one or more data blocks of the plurality of data blocks. The approaches may include generating an output based at least in part on the anomaly storage check.

公开(公告)号：US10924414B2

公开(公告)日：2021-02-16

申请号：US16545642

申请日：2019-08-20

Applicant: eBay Inc.

Inventor： Sharad R. Murthy ,  Bhaven Avalani ,  Hongyue Nemo Chen ,  Tony Chung Tung Ng ,  Weiwei Jin ,  Xinglang Wang ,  Mingming Wang ,  Wei Fang

IPC: H04L29/08 ,  H04L29/06 ,  H04L12/801 ,  G06F15/17 ,  G06F15/16 ,  G06Q10/10 ,  G06Q20/32 ,  G06Q30/00 ,  H04L12/835

Abstract: Disclosed are a system comprising a computer-readable storage medium storing at least one program, and a computer-implemented method for event messaging over a network. A subscription interface receives data indicative of a subscription request for sessionized data. An allocation module allocates a sessionizer bank linked to the subscription request. A messaging interface module provisions identifiers linked to the respective processing engines of the sessionizer bank. The messaging interface module registers the allocated sessionizer bank as available to process event messages matching the subscription request by providing the provisioned identifiers. The messaging interface module receives event messages from a producer device linked by a collection server to a selected one of the processing engines of the sessionizer bank. The selected one of the processing engine processes the received event messages in accordance with session rule data linked to the subscription request to generate sessionized data.