| Modifier and Type | Method and Description |
|---|---|
void |
GrowingAPI.send(GIOMessage msg)
添加埋点事件.
|
void |
GrowingAPI.sendMaybeRejected(GIOMessage msg)
添加埋点事件,当队列满时,可以抛出拒绝异常.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GioCdpEventMessage |
class |
GioCdpItemMessage |
class |
GioCDPMessage<M extends com.google.protobuf.Message> |
class |
GioCdpUserMappingMessage |
class |
GioCdpUserMessage |
| Modifier and Type | Method and Description |
|---|---|
static MessageProcessor |
EventProcessorClient.getApiInstance(GIOMessage msg) |
boolean |
MessageProcessor.skipIllegalMessage(GIOMessage gioMessage) |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
MessageProcessor.process(List<GIOMessage> msgList) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
AbstractMessageProcessor.skipIllegalMessage(GIOMessage gioMessage) |
| Modifier and Type | Method and Description |
|---|---|
protected String |
GioCdpUserMappingMessageProcessor.debugMessage(List<GIOMessage> msgList) |
protected String |
GioCdpItemMessageProcessor.debugMessage(List<GIOMessage> msgList) |
protected String |
GioCdpEventMessageProcessor.debugMessage(List<GIOMessage> msgList) |
protected String |
GioCdpUserMessageProcessor.debugMessage(List<GIOMessage> msgList) |
protected abstract String |
AbstractMessageProcessor.debugMessage(List<GIOMessage> msgList) |
protected byte[] |
GioCdpUserMappingMessageProcessor.doProcess(List<GIOMessage> msgList) |
protected byte[] |
GioCdpItemMessageProcessor.doProcess(List<GIOMessage> msgList) |
protected byte[] |
GioCdpEventMessageProcessor.doProcess(List<GIOMessage> msgList) |
protected byte[] |
GioCdpUserMessageProcessor.doProcess(List<GIOMessage> msgList) |
protected abstract byte[] |
AbstractMessageProcessor.doProcess(List<GIOMessage> msgList) |
byte[] |
AbstractMessageProcessor.process(List<GIOMessage> msgList) |
| Modifier and Type | Method and Description |
|---|---|
void |
FixThreadPoolSender.doSend(String projectKey,
List<GIOMessage> msgList) |
void |
FixThreadPoolSender.sendMsg(String projectKey,
List<GIOMessage> msg) |
void |
MessageSender.sendMsg(String projectKey,
List<GIOMessage> msg) |
| Modifier and Type | Field and Description |
|---|---|
protected static BlockingQueue<GIOMessage> |
StoreStrategyAbstract.messageBlockingQueue |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
StoreStrategyAbstract.doPush(GIOMessage msg) |
void |
StoreStrategyAbstract.push(GIOMessage msg) |
void |
StoreStrategy.push(GIOMessage msgList) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultStoreStrategy.doPush(GIOMessage msg) |
void |
AbortPolicyStoreStrategy.doPush(GIOMessage msg) |
Copyright © 2022. All rights reserved.