define

Documentation

Index

• Constants
• func TopicRepeatDuplicateKey(dispatcherEventID string) string
• type ConnectorType
• type EndPoint
• type EventType
• type InternalHandlerReq
• type InternalHandlerRsp
• type SendReq
• type SendRsp

Constants

const (
	EventTypeInternal = 1
	EventTypeExternal = 2
)

const (
	ProtocolTypeGRPCSend = "grpcSend"
	ProtocolTypeHTTPSend = "httpSend"

	ProtocolTypeGRPCInternalHandler = "grpcInternalHandler"
)

const (
	RepeatDuplicatePre       = "1"
	RepeatDuplicateCommitted = "2"
	RepeatDuplicatePreFirst  = "3"
	RepeatDuplicateGetErr    = "5"
	RepeatDuplicateSetErr    = "6"
)

const (
	KeyRepeatDuplicate = "evhub:processor:repeat:duplicate:%v"

	RepeatDuplicateTimeOut = 60
)

const (
	RepeatDuplicateScript = `` /* 464-byte string literal not displayed */

)

Functions

func TopicRepeatDuplicateKey

func TopicRepeatDuplicateKey(dispatcherEventID string) string

TopicRepeatDuplicateKey returns the duplicate key for a topic

Types

type ConnectorType

type ConnectorType string

ConnectorType connector type

const (
	ConnectorTypePulsar ConnectorType = "pulsar"
	ConnectorTypeNsq    ConnectorType = "nsq"

	ConnectorTypeKafka ConnectorType = "kafka"
)

type EndPoint

type EndPoint struct {
	Addr    string
	Timeout time.Duration
}

EndPoint information about the address

type EventType

type EventType int

EventType event type

type InternalHandlerReq

type InternalHandlerReq struct {
	Msg      *comm.EvhubMsg
	EndPoint *EndPoint
}

InternalHandlerReq is req of the internal handler

type InternalHandlerRsp

type InternalHandlerRsp struct {
}

InternalHandlerRsp is rsp of the internal handler

type SendReq

type SendReq struct {
	DispatchID  string
	EventID     string
	Event       *comm.Event
	RetryTimes  uint32
	RepeatTimes uint32
	PassBack    []byte
	EndPoint    *EndPoint
}

SendReq is req of the dispatcher

type SendRsp

type SendRsp struct {
	PassBack []byte
}

SendRsp is rsp of the dispatcher