define

Documentation

Index

• Constants
• type CallbackReq
• type CallbackRsp
• type CommitReq
• type CommitRsp
• type ConnectorType
• type InternalHandlerReq
• type InternalHandlerRsp
• type PrepareReq
• type PrepareRsp
• type ReportReq
• type ReportRsp
• type RollbackReq
• type RollbackRsp
• type TxEventMsg

Constants

const (
	ReportEventReport   = "report"
	ReportEventPrepare  = "prepare"
	ReportEventCommit   = "commit"
	ReportEventRollback = "rollback"
	InternalHandler     = "internalHandler"
	ReportEventCallback = "callback"

	PackProtocolHTTPJSON = "httpJson"
	PackProtocolGrpc     = "grpc"
)

const (
	EventAppID   string = "event_app_id"
	EventTopicID string = "event_topic_id"
)

Types

type CallbackReq

type CallbackReq struct {
	TxEventMsg *TxEventMsg `json:"txEventMsg,omitempty"`
}

CallbackReq is the name of the callback request

type CallbackRsp

type CallbackRsp struct {
}

CallbackRsp is the name of the callback response

type CommitReq

type CommitReq struct {
	EventID string             `json:"eventID,omitempty"`
	Trigger *comm.EventTrigger `json:"trigger,omitempty"`
}

CommitReq is the name of the commit request

type CommitRsp

type CommitRsp struct {
	Ret *comm.Result `json:"ret,omitempty"`
	Tx  *comm.Tx     `json:"tx,omitempty"`
}

CommitRsp is the name of the commit response

type ConnectorType

type ConnectorType string

ConnectorType is the name of the connector type

const (
	// ConnectorTypePulsar is the connector type of the pulsar
	ConnectorTypePulsar ConnectorType = "pulsar"
	// ConnectorTypeNsq is the connector type of the nsq
	ConnectorTypeNsq ConnectorType = "nsq"
	// ConnectorTypeKafka is the connector type of the kafka
	ConnectorTypeKafka ConnectorType = "kafka"
)

type InternalHandlerReq

type InternalHandlerReq struct {
	EvhubMsg *comm.EvhubMsg `json:"evhubMsg,omitempty"`
}

InternalHandlerReq is the name of the internal handler request

type InternalHandlerRsp

type InternalHandlerRsp struct {
	Ret *comm.Result `json:"ret,omitempty"`
}

InternalHandlerRsp is the name of the internal handler response

type PrepareReq

type PrepareReq struct {
	Event      *comm.Event      `json:"event,omitempty"`
	TxCallback *comm.TxCallback `json:"txCallback,omitempty"`
}

PrepareReq is the name of the prepare request

type PrepareRsp

type PrepareRsp struct {
	Tx  *comm.Tx     `json:"tx,omitempty"`
	Ret *comm.Result `json:"ret,omitempty"`
}

PrepareRsp is the name of the prepare response

type ReportReq

type ReportReq struct {
	Event   *comm.Event        `json:"event,omitempty"`
	Trigger *comm.EventTrigger `json:"trigger,omitempty"`
	Option  *comm.EventOption  `json:"option,omitempty"`
}

ReportReq is the name of the report request

type ReportRsp

type ReportRsp struct {
	EventID string       `json:"event_id,omitempty"`
	Ret     *comm.Result `json:"ret,omitempty"`
}

ReportRsp is the name of the report response

type RollbackReq

type RollbackReq struct {
	EventID string `json:"eventID,omitempty"`
}

RollbackReq is the name of the rollback request

type RollbackRsp

type RollbackRsp struct {
	Ret *comm.Result `json:"ret,omitempty"`
	Tx  *comm.Tx     `json:"tx,omitempty"`
}

RollbackRsp is the name of the rollback response

type TxEventMsg

type TxEventMsg struct {
	Ctx         interface{}        `json:"ctx"`
	AppID       string             `json:"app_id"`
	TopicID     string             `json:"topic_id"`
	EventID     string             `json:"event_id"`
	DelayTimeMs uint32             `json:"delay_time_ms"`
	RetryCount  uint32             `json:"retry_count"`
	Trigger     *comm.EventTrigger `json:"trigger"`
	Type        int                `json:"type"`
}

TxEventMsg is the name of the transaction event