comm

package
v0.0.0-...-d5b0b98 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 1 more Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EventTriggerType_name = map[int32]string{
		0: "EVENT_TRIGGER_TYPE_INVALID",
		1: "EVENT_TRIGGER_TYPE_REAL_TIME",
		2: "EVENT_TRIGGER_TYPE_DELAY",
		3: "EVENT_TRIGGER_TYPE_REPEAT",
		4: "EVENT_TRIGGER_TYPE_DELAY_PROCESS",
	}
	EventTriggerType_value = map[string]int32{
		"EVENT_TRIGGER_TYPE_INVALID":       0,
		"EVENT_TRIGGER_TYPE_REAL_TIME":     1,
		"EVENT_TRIGGER_TYPE_DELAY":         2,
		"EVENT_TRIGGER_TYPE_REPEAT":        3,
		"EVENT_TRIGGER_TYPE_DELAY_PROCESS": 4,
	}
)

Enum value maps for EventTriggerType.

View Source 
var (
	EventRepeatEndType_name = map[int32]string{
		0: "EVENT_REPEAT_END_TYPE_INVALID",
		1: "EVENT_REPEAT_END_TYPE_END_BY_TIMESTAMP",
		2: "EVENT_REPEAT_END_TYPE_END_BY_COUNT",
	}
	EventRepeatEndType_value = map[string]int32{
		"EVENT_REPEAT_END_TYPE_INVALID":          0,
		"EVENT_REPEAT_END_TYPE_END_BY_TIMESTAMP": 1,
		"EVENT_REPEAT_END_TYPE_END_BY_COUNT":     2,
	}
)

Enum value maps for EventRepeatEndType.

View Source 
var (
	EventPulserType_name = map[int32]string{
		0: "EVENT_PULSER_TYPE_INVALID",
		1: "EVENT_PULSER_TYPE_BY_INTERVAL",
		2: "EVENT_PULSER_TYPE_BY_CRONTAB",
	}
	EventPulserType_value = map[string]int32{
		"EVENT_PULSER_TYPE_INVALID":     0,
		"EVENT_PULSER_TYPE_BY_INTERVAL": 1,
		"EVENT_PULSER_TYPE_BY_CRONTAB":  2,
	}
)

Enum value maps for EventPulserType.

View Source 
var (
	TxStatus_name = map[int32]string{
		0: "TX_STATUS_INVALID",
		1: "TX_STATUS_PREPARE",
		2: "TX_STATUS_COMMIT",
		3: "TX_STATUS_ROLLBACK",
		4: "TX_STATUS_SUCCESS",
	}
	TxStatus_value = map[string]int32{
		"TX_STATUS_INVALID":  0,
		"TX_STATUS_PREPARE":  1,
		"TX_STATUS_COMMIT":   2,
		"TX_STATUS_ROLLBACK": 3,
		"TX_STATUS_SUCCESS":  4,
	}
)

Enum value maps for TxStatus.

View Source 
var (
	ProtocolType_name = map[int32]string{
		0: "PROTOCOL_TYPE_INVALID",
		1: "PROTOCOL_TYPE_GRPC",
		3: "PROTOCOL_TYPE_HTTP_PB",
		5: "PROTOCOL_TYPE_HTTP_JSON",
	}
	ProtocolType_value = map[string]int32{
		"PROTOCOL_TYPE_INVALID":   0,
		"PROTOCOL_TYPE_GRPC":      1,
		"PROTOCOL_TYPE_HTTP_PB":   3,
		"PROTOCOL_TYPE_HTTP_JSON": 5,
	}
)

Enum value maps for ProtocolType.

View Source 
var (
	EventStatus_name = map[int32]string{
		0:   "EVENT_STATUS_INVALID",
		1:   "EVENT_STATUS_MAKING",
		100: "EVENT_STATUS_INIT",
		200: "EVENT_STATUS_IN_REAL_TIME_QUEUE",
		201: "EVENT_STATUS_RETEY_IN_REAL_TIME_QUEUE",
		202: "EVENT_STATUS_REPEAT_IN_REAL_TIME_QUEUE",
		203: "EVENT_STATUS_DELAY_PROCESS_IN_REAL_TIME_QUEUE",
		300: "EVENT_STATUS_IN_DELAY_QUEUE",
		301: "EVENT_STATUS_RETEY_IN_DELAY_QUEUE",
		302: "EVENT_STATUS_REPEAT_IN_DELAY_QUEUE",
		303: "EVENT_STATUS_DELAY_PROCESS_IN_DELAY_QUEUE",
		304: "EVENT_STATUS_TX_CALLBACK_IN_DELAY_QUEUE",
		400: "EVENT_STATUS_DELAY_RIGGER",
		500: "EVENT_STATUS_WAIT_PROCESS",
		501: "EVENT_STATUS_PROCESS_SUCC",
		502: "EVENT_STATUS_PROCESS_FAILED",
	}
	EventStatus_value = map[string]int32{
		"EVENT_STATUS_INVALID":                          0,
		"EVENT_STATUS_MAKING":                           1,
		"EVENT_STATUS_INIT":                             100,
		"EVENT_STATUS_IN_REAL_TIME_QUEUE":               200,
		"EVENT_STATUS_RETEY_IN_REAL_TIME_QUEUE":         201,
		"EVENT_STATUS_REPEAT_IN_REAL_TIME_QUEUE":        202,
		"EVENT_STATUS_DELAY_PROCESS_IN_REAL_TIME_QUEUE": 203,
		"EVENT_STATUS_IN_DELAY_QUEUE":                   300,
		"EVENT_STATUS_RETEY_IN_DELAY_QUEUE":             301,
		"EVENT_STATUS_REPEAT_IN_DELAY_QUEUE":            302,
		"EVENT_STATUS_DELAY_PROCESS_IN_DELAY_QUEUE":     303,
		"EVENT_STATUS_TX_CALLBACK_IN_DELAY_QUEUE":       304,
		"EVENT_STATUS_DELAY_RIGGER":                     400,
		"EVENT_STATUS_WAIT_PROCESS":                     500,
		"EVENT_STATUS_PROCESS_SUCC":                     501,
		"EVENT_STATUS_PROCESS_FAILED":                   502,
	}
)

Enum value maps for EventStatus.

View Source 
var File_comm_comm_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CrontabPulser 

type CrontabPulser struct {
	Crontab string `protobuf:"bytes,1,opt,name=crontab,proto3" json:"crontab,omitempty"`
	// contains filtered or unexported fields
}

crontab

func (*CrontabPulser) Descriptor deprecated 

func (*CrontabPulser) Descriptor() ([]byte, []int)

Deprecated: Use CrontabPulser.ProtoReflect.Descriptor instead.

func (*CrontabPulser) GetCrontab 

func (x *CrontabPulser) GetCrontab() string

func (*CrontabPulser) ProtoMessage 

func (*CrontabPulser) ProtoMessage()

func (*CrontabPulser) ProtoReflect 

func (x *CrontabPulser) ProtoReflect() protoreflect.Message

func (*CrontabPulser) Reset 

func (x *CrontabPulser) Reset()

func (*CrontabPulser) String 

func (x *CrontabPulser) String() string

type Endpoint 

type Endpoint struct {

	// 0:invalid 1:grpc  3:http
	ProtocolType ProtocolType       `` /* 127-byte string literal not displayed */
	Address      string             `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Timeout      *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor deprecated 

func (*Endpoint) Descriptor() ([]byte, []int)

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetAddress 

func (x *Endpoint) GetAddress() string

func (*Endpoint) GetProtocolType 

func (x *Endpoint) GetProtocolType() ProtocolType

func (*Endpoint) GetTimeout 

func (x *Endpoint) GetTimeout() *duration.Duration

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

func (x *Endpoint) ProtoReflect() protoreflect.Message

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) String 

func (x *Endpoint) String() string

type Err 

type Err struct {
	Code     int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg      string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	PassBack []byte `protobuf:"bytes,3,opt,name=pass_back,json=passBack,proto3" json:"pass_back,omitempty"`
	// contains filtered or unexported fields
}

func (*Err) Descriptor deprecated 

func (*Err) Descriptor() ([]byte, []int)

Deprecated: Use Err.ProtoReflect.Descriptor instead.

func (*Err) GetCode 

func (x *Err) GetCode() int32

func (*Err) GetMsg 

func (x *Err) GetMsg() string

func (*Err) GetPassBack 

func (x *Err) GetPassBack() []byte

func (*Err) ProtoMessage 

func (*Err) ProtoMessage()

func (*Err) ProtoReflect 

func (x *Err) ProtoReflect() protoreflect.Message

func (*Err) Reset 

func (x *Err) Reset()

func (*Err) String 

func (x *Err) String() string

type Event 

type Event struct {
	AppId     string     `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	TopicId   string     `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	EventComm *EventComm `protobuf:"bytes,3,opt,name=event_comm,json=eventComm,proto3" json:"event_comm,omitempty"`
	Data      []byte     `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAppId 

func (x *Event) GetAppId() string

func (*Event) GetData 

func (x *Event) GetData() []byte

func (*Event) GetEventComm 

func (x *Event) GetEventComm() *EventComm

func (*Event) GetTopicId 

func (x *Event) GetTopicId() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventComm 

type EventComm struct {
	EventSource *EventSource `protobuf:"bytes,1,opt,name=event_source,json=eventSource,proto3" json:"event_source,omitempty"`
	EventTag    *EventTag    `protobuf:"bytes,2,opt,name=event_tag,json=eventTag,proto3" json:"event_tag,omitempty"`
	// contains filtered or unexported fields
}

func (*EventComm) Descriptor deprecated 

func (*EventComm) Descriptor() ([]byte, []int)

Deprecated: Use EventComm.ProtoReflect.Descriptor instead.

func (*EventComm) GetEventSource 

func (x *EventComm) GetEventSource() *EventSource

func (*EventComm) GetEventTag 

func (x *EventComm) GetEventTag() *EventTag

func (*EventComm) ProtoMessage 

func (*EventComm) ProtoMessage()

func (*EventComm) ProtoReflect 

func (x *EventComm) ProtoReflect() protoreflect.Message

func (*EventComm) Reset 

func (x *EventComm) Reset()

func (*EventComm) String 

func (x *EventComm) String() string

type EventDelayProcessTrigger 

type EventDelayProcessTrigger struct {
	Key       string             `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	DelayTime *duration.Duration `protobuf:"bytes,2,opt,name=delay_time,json=delayTime,proto3" json:"delay_time,omitempty"`
	// contains filtered or unexported fields
}

func (*EventDelayProcessTrigger) Descriptor deprecated 

func (*EventDelayProcessTrigger) Descriptor() ([]byte, []int)

Deprecated: Use EventDelayProcessTrigger.ProtoReflect.Descriptor instead.

func (*EventDelayProcessTrigger) GetDelayTime 

func (x *EventDelayProcessTrigger) GetDelayTime() *duration.Duration

func (*EventDelayProcessTrigger) GetKey 

func (x *EventDelayProcessTrigger) GetKey() string

func (*EventDelayProcessTrigger) ProtoMessage 

func (*EventDelayProcessTrigger) ProtoMessage()

func (*EventDelayProcessTrigger) ProtoReflect 

func (x *EventDelayProcessTrigger) ProtoReflect() protoreflect.Message

func (*EventDelayProcessTrigger) Reset 

func (x *EventDelayProcessTrigger) Reset()

func (*EventDelayProcessTrigger) String 

func (x *EventDelayProcessTrigger) String() string

type EventDelayTrigger 

type EventDelayTrigger struct {
	DelayTime *duration.Duration `protobuf:"bytes,1,opt,name=delay_time,json=delayTime,proto3" json:"delay_time,omitempty"`
	// contains filtered or unexported fields
}

func (*EventDelayTrigger) Descriptor deprecated 

func (*EventDelayTrigger) Descriptor() ([]byte, []int)

Deprecated: Use EventDelayTrigger.ProtoReflect.Descriptor instead.

func (*EventDelayTrigger) GetDelayTime 

func (x *EventDelayTrigger) GetDelayTime() *duration.Duration

func (*EventDelayTrigger) ProtoMessage 

func (*EventDelayTrigger) ProtoMessage()

func (*EventDelayTrigger) ProtoReflect 

func (x *EventDelayTrigger) ProtoReflect() protoreflect.Message

func (*EventDelayTrigger) Reset 

func (x *EventDelayTrigger) Reset()

func (*EventDelayTrigger) String 

func (x *EventDelayTrigger) String() string

type EventDispatcherInfo 

type EventDispatcherInfo struct {
	DispatcherId string `protobuf:"bytes,1,opt,name=dispatcher_id,json=dispatcherId,proto3" json:"dispatcher_id,omitempty"`
	RetryTimes   uint32 `protobuf:"varint,2,opt,name=retry_times,json=retryTimes,proto3" json:"retry_times,omitempty"`
	PassBack     []byte `protobuf:"bytes,3,opt,name=pass_back,json=passBack,proto3" json:"pass_back,omitempty"`
	// contains filtered or unexported fields
}

func (*EventDispatcherInfo) Descriptor deprecated 

func (*EventDispatcherInfo) Descriptor() ([]byte, []int)

Deprecated: Use EventDispatcherInfo.ProtoReflect.Descriptor instead.

func (*EventDispatcherInfo) GetDispatcherId 

func (x *EventDispatcherInfo) GetDispatcherId() string

func (*EventDispatcherInfo) GetPassBack 

func (x *EventDispatcherInfo) GetPassBack() []byte

func (*EventDispatcherInfo) GetRetryTimes 

func (x *EventDispatcherInfo) GetRetryTimes() uint32

func (*EventDispatcherInfo) ProtoMessage 

func (*EventDispatcherInfo) ProtoMessage()

func (*EventDispatcherInfo) ProtoReflect 

func (x *EventDispatcherInfo) ProtoReflect() protoreflect.Message

func (*EventDispatcherInfo) Reset 

func (x *EventDispatcherInfo) Reset()

func (*EventDispatcherInfo) String 

func (x *EventDispatcherInfo) String() string

type EventIdempotent 

type EventIdempotent struct {
	Key            string             `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	IdempotentTime *duration.Duration `protobuf:"bytes,2,opt,name=idempotent_time,json=idempotentTime,proto3" json:"idempotent_time,omitempty"`
	// contains filtered or unexported fields
}

func (*EventIdempotent) Descriptor deprecated 

func (*EventIdempotent) Descriptor() ([]byte, []int)

Deprecated: Use EventIdempotent.ProtoReflect.Descriptor instead.

func (*EventIdempotent) GetIdempotentTime 

func (x *EventIdempotent) GetIdempotentTime() *duration.Duration

func (*EventIdempotent) GetKey 

func (x *EventIdempotent) GetKey() string

func (*EventIdempotent) ProtoMessage 

func (*EventIdempotent) ProtoMessage()

func (*EventIdempotent) ProtoReflect 

func (x *EventIdempotent) ProtoReflect() protoreflect.Message

func (*EventIdempotent) Reset 

func (x *EventIdempotent) Reset()

func (*EventIdempotent) String 

func (x *EventIdempotent) String() string

type EventOption 

type EventOption struct {
	Idempotent  *EventIdempotent `protobuf:"bytes,1,opt,name=idempotent,proto3" json:"idempotent,omitempty"`
	OrderingKey string           `protobuf:"bytes,2,opt,name=orderingKey,proto3" json:"orderingKey,omitempty"`
	// contains filtered or unexported fields
}

func (*EventOption) Descriptor deprecated 

func (*EventOption) Descriptor() ([]byte, []int)

Deprecated: Use EventOption.ProtoReflect.Descriptor instead.

func (*EventOption) GetIdempotent 

func (x *EventOption) GetIdempotent() *EventIdempotent

func (*EventOption) GetOrderingKey 

func (x *EventOption) GetOrderingKey() string

func (*EventOption) ProtoMessage 

func (*EventOption) ProtoMessage()

func (*EventOption) ProtoReflect 

func (x *EventOption) ProtoReflect() protoreflect.Message

func (*EventOption) Reset 

func (x *EventOption) Reset()

func (*EventOption) String 

func (x *EventOption) String() string

type EventPulserType 

type EventPulserType int32
const (
	//INVALID
	EventPulserType_EVENT_PULSER_TYPE_INVALID     EventPulserType = 0
	EventPulserType_EVENT_PULSER_TYPE_BY_INTERVAL EventPulserType = 1
	EventPulserType_EVENT_PULSER_TYPE_BY_CRONTAB  EventPulserType = 2
)

func (EventPulserType) Descriptor 

func (EventPulserType) Descriptor() protoreflect.EnumDescriptor

func (EventPulserType) Enum 

func (x EventPulserType) Enum() *EventPulserType

func (EventPulserType) EnumDescriptor deprecated 

func (EventPulserType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventPulserType.Descriptor instead.

func (EventPulserType) Number 

func (x EventPulserType) Number() protoreflect.EnumNumber

func (EventPulserType) String 

func (x EventPulserType) String() string

func (EventPulserType) Type 

func (EventPulserType) Type() protoreflect.EnumType

type EventRepeatEndType 

type EventRepeatEndType int32
const (
	//INVALID
	EventRepeatEndType_EVENT_REPEAT_END_TYPE_INVALID          EventRepeatEndType = 0
	EventRepeatEndType_EVENT_REPEAT_END_TYPE_END_BY_TIMESTAMP EventRepeatEndType = 1
	EventRepeatEndType_EVENT_REPEAT_END_TYPE_END_BY_COUNT     EventRepeatEndType = 2
)

func (EventRepeatEndType) Descriptor 

func (EventRepeatEndType) Descriptor() protoreflect.EnumDescriptor

func (EventRepeatEndType) Enum 

func (x EventRepeatEndType) Enum() *EventRepeatEndType

func (EventRepeatEndType) EnumDescriptor deprecated 

func (EventRepeatEndType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventRepeatEndType.Descriptor instead.

func (EventRepeatEndType) Number 

func (x EventRepeatEndType) Number() protoreflect.EnumNumber

func (EventRepeatEndType) String 

func (x EventRepeatEndType) String() string

func (EventRepeatEndType) Type 

func (EventRepeatEndType) Type() protoreflect.EnumType

type EventRepeatTrigger 

type EventRepeatTrigger struct {
	BeginTime     *timestamp.Timestamp `protobuf:"bytes,1,opt,name=begin_time,json=beginTime,proto3" json:"begin_time,omitempty"`
	EndType       EventRepeatEndType   `protobuf:"varint,2,opt,name=end_type,json=endType,proto3,enum=evhub_comm.EventRepeatEndType" json:"end_type,omitempty"`
	RepeatEnd     *RepeatEnd           `protobuf:"bytes,3,opt,name=repeat_end,json=repeatEnd,proto3" json:"repeat_end,omitempty"`
	PulserType    EventPulserType      `protobuf:"varint,4,opt,name=pulser_type,json=pulserType,proto3,enum=evhub_comm.EventPulserType" json:"pulser_type,omitempty"`
	RegularPulser *RegularPulser       `protobuf:"bytes,5,opt,name=regular_pulser,json=regularPulser,proto3" json:"regular_pulser,omitempty"`
	CrontabPulser *CrontabPulser       `protobuf:"bytes,6,opt,name=crontab_pulser,json=crontabPulser,proto3" json:"crontab_pulser,omitempty"`
	// contains filtered or unexported fields
}

func (*EventRepeatTrigger) Descriptor deprecated 

func (*EventRepeatTrigger) Descriptor() ([]byte, []int)

Deprecated: Use EventRepeatTrigger.ProtoReflect.Descriptor instead.

func (*EventRepeatTrigger) GetBeginTime 

func (x *EventRepeatTrigger) GetBeginTime() *timestamp.Timestamp

func (*EventRepeatTrigger) GetCrontabPulser 

func (x *EventRepeatTrigger) GetCrontabPulser() *CrontabPulser

func (*EventRepeatTrigger) GetEndType 

func (x *EventRepeatTrigger) GetEndType() EventRepeatEndType

func (*EventRepeatTrigger) GetPulserType 

func (x *EventRepeatTrigger) GetPulserType() EventPulserType

func (*EventRepeatTrigger) GetRegularPulser 

func (x *EventRepeatTrigger) GetRegularPulser() *RegularPulser

func (*EventRepeatTrigger) GetRepeatEnd 

func (x *EventRepeatTrigger) GetRepeatEnd() *RepeatEnd

func (*EventRepeatTrigger) ProtoMessage 

func (*EventRepeatTrigger) ProtoMessage()

func (*EventRepeatTrigger) ProtoReflect 

func (x *EventRepeatTrigger) ProtoReflect() protoreflect.Message

func (*EventRepeatTrigger) Reset 

func (x *EventRepeatTrigger) Reset()

func (*EventRepeatTrigger) String 

func (x *EventRepeatTrigger) String() string

type EventSource 

type EventSource struct {
	Source     string               `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Qua        string               `protobuf:"bytes,2,opt,name=qua,proto3" json:"qua,omitempty"`
	CreateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSource) Descriptor deprecated 

func (*EventSource) Descriptor() ([]byte, []int)

Deprecated: Use EventSource.ProtoReflect.Descriptor instead.

func (*EventSource) GetCreateTime 

func (x *EventSource) GetCreateTime() *timestamp.Timestamp

func (*EventSource) GetQua 

func (x *EventSource) GetQua() string

func (*EventSource) GetSource 

func (x *EventSource) GetSource() string

func (*EventSource) ProtoMessage 

func (*EventSource) ProtoMessage()

func (*EventSource) ProtoReflect 

func (x *EventSource) ProtoReflect() protoreflect.Message

func (*EventSource) Reset 

func (x *EventSource) Reset()

func (*EventSource) String 

func (x *EventSource) String() string

type EventStatus 

type EventStatus int32
const (
	EventStatus_EVENT_STATUS_INVALID                          EventStatus = 0   //INVALID
	EventStatus_EVENT_STATUS_MAKING                           EventStatus = 1   //
	EventStatus_EVENT_STATUS_INIT                             EventStatus = 100 //
	EventStatus_EVENT_STATUS_IN_REAL_TIME_QUEUE               EventStatus = 200 //
	EventStatus_EVENT_STATUS_RETEY_IN_REAL_TIME_QUEUE         EventStatus = 201 //
	EventStatus_EVENT_STATUS_REPEAT_IN_REAL_TIME_QUEUE        EventStatus = 202 //
	EventStatus_EVENT_STATUS_DELAY_PROCESS_IN_REAL_TIME_QUEUE EventStatus = 203 //
	EventStatus_EVENT_STATUS_IN_DELAY_QUEUE                   EventStatus = 300 //
	EventStatus_EVENT_STATUS_RETEY_IN_DELAY_QUEUE             EventStatus = 301 //
	EventStatus_EVENT_STATUS_REPEAT_IN_DELAY_QUEUE            EventStatus = 302 //
	EventStatus_EVENT_STATUS_DELAY_PROCESS_IN_DELAY_QUEUE     EventStatus = 303 //
	EventStatus_EVENT_STATUS_TX_CALLBACK_IN_DELAY_QUEUE       EventStatus = 304 //
	EventStatus_EVENT_STATUS_DELAY_RIGGER                     EventStatus = 400 //
	EventStatus_EVENT_STATUS_WAIT_PROCESS                     EventStatus = 500 //
	EventStatus_EVENT_STATUS_PROCESS_SUCC                     EventStatus = 501 //
	EventStatus_EVENT_STATUS_PROCESS_FAILED                   EventStatus = 502 //
)

func (EventStatus) Descriptor 

func (EventStatus) Descriptor() protoreflect.EnumDescriptor

func (EventStatus) Enum 

func (x EventStatus) Enum() *EventStatus

func (EventStatus) EnumDescriptor deprecated 

func (EventStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventStatus.Descriptor instead.

func (EventStatus) Number 

func (x EventStatus) Number() protoreflect.EnumNumber

func (EventStatus) String 

func (x EventStatus) String() string

func (EventStatus) Type 

func (EventStatus) Type() protoreflect.EnumType

type EventTag 

type EventTag struct {

	//tag
	TagList []string `protobuf:"bytes,1,rep,name=tag_list,json=tagList,proto3" json:"tag_list,omitempty"`
	// contains filtered or unexported fields
}

tag

func (*EventTag) Descriptor deprecated 

func (*EventTag) Descriptor() ([]byte, []int)

Deprecated: Use EventTag.ProtoReflect.Descriptor instead.

func (*EventTag) GetTagList 

func (x *EventTag) GetTagList() []string

func (*EventTag) ProtoMessage 

func (*EventTag) ProtoMessage()

func (*EventTag) ProtoReflect 

func (x *EventTag) ProtoReflect() protoreflect.Message

func (*EventTag) Reset 

func (x *EventTag) Reset()

func (*EventTag) String 

func (x *EventTag) String() string

type EventTrigger 

type EventTrigger struct {
	TriggerType             EventTriggerType            `` /* 128-byte string literal not displayed */
	DelayTrigger            *EventDelayTrigger          `protobuf:"bytes,2,opt,name=delay_trigger,json=delayTrigger,proto3" json:"delay_trigger,omitempty"`
	RepeatTrigger           *EventRepeatTrigger         `protobuf:"bytes,3,opt,name=repeat_trigger,json=repeatTrigger,proto3" json:"repeat_trigger,omitempty"`
	DelayProcessTriggerList []*EventDelayProcessTrigger `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventTrigger) Descriptor deprecated 

func (*EventTrigger) Descriptor() ([]byte, []int)

Deprecated: Use EventTrigger.ProtoReflect.Descriptor instead.

func (*EventTrigger) GetDelayProcessTriggerList 

func (x *EventTrigger) GetDelayProcessTriggerList() []*EventDelayProcessTrigger

func (*EventTrigger) GetDelayTrigger 

func (x *EventTrigger) GetDelayTrigger() *EventDelayTrigger

func (*EventTrigger) GetRepeatTrigger 

func (x *EventTrigger) GetRepeatTrigger() *EventRepeatTrigger

func (*EventTrigger) GetTriggerType 

func (x *EventTrigger) GetTriggerType() EventTriggerType

func (*EventTrigger) ProtoMessage 

func (*EventTrigger) ProtoMessage()

func (*EventTrigger) ProtoReflect 

func (x *EventTrigger) ProtoReflect() protoreflect.Message

func (*EventTrigger) Reset 

func (x *EventTrigger) Reset()

func (*EventTrigger) String 

func (x *EventTrigger) String() string

type EventTriggerInfo 

type EventTriggerInfo struct {
	Trigger     *EventTrigger `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	RepeatTimes uint32        `protobuf:"varint,2,opt,name=repeat_times,json=repeatTimes,proto3" json:"repeat_times,omitempty"`
	// contains filtered or unexported fields
}

func (*EventTriggerInfo) Descriptor deprecated 

func (*EventTriggerInfo) Descriptor() ([]byte, []int)

Deprecated: Use EventTriggerInfo.ProtoReflect.Descriptor instead.

func (*EventTriggerInfo) GetRepeatTimes 

func (x *EventTriggerInfo) GetRepeatTimes() uint32

func (*EventTriggerInfo) GetTrigger 

func (x *EventTriggerInfo) GetTrigger() *EventTrigger

func (*EventTriggerInfo) ProtoMessage 

func (*EventTriggerInfo) ProtoMessage()

func (*EventTriggerInfo) ProtoReflect 

func (x *EventTriggerInfo) ProtoReflect() protoreflect.Message

func (*EventTriggerInfo) Reset 

func (x *EventTriggerInfo) Reset()

func (*EventTriggerInfo) String 

func (x *EventTriggerInfo) String() string

type EventTriggerType 

type EventTriggerType int32
const (
	//INVALID
	EventTriggerType_EVENT_TRIGGER_TYPE_INVALID       EventTriggerType = 0
	EventTriggerType_EVENT_TRIGGER_TYPE_REAL_TIME     EventTriggerType = 1
	EventTriggerType_EVENT_TRIGGER_TYPE_DELAY         EventTriggerType = 2
	EventTriggerType_EVENT_TRIGGER_TYPE_REPEAT        EventTriggerType = 3
	EventTriggerType_EVENT_TRIGGER_TYPE_DELAY_PROCESS EventTriggerType = 4
)

func (EventTriggerType) Descriptor 

func (EventTriggerType) Descriptor() protoreflect.EnumDescriptor

func (EventTriggerType) Enum 

func (x EventTriggerType) Enum() *EventTriggerType

func (EventTriggerType) EnumDescriptor deprecated 

func (EventTriggerType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventTriggerType.Descriptor instead.

func (EventTriggerType) Number 

func (x EventTriggerType) Number() protoreflect.EnumNumber

func (EventTriggerType) String 

func (x EventTriggerType) String() string

func (EventTriggerType) Type 

func (EventTriggerType) Type() protoreflect.EnumType

type EvhubMsg 

type EvhubMsg struct {
	EventId        string               `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Status         EventStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=evhub_comm.EventStatus" json:"status,omitempty"`
	Event          *Event               `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	TriggerInfo    *EventTriggerInfo    `protobuf:"bytes,4,opt,name=trigger_info,json=triggerInfo,proto3" json:"trigger_info,omitempty"`
	DispatcherInfo *EventDispatcherInfo `protobuf:"bytes,5,opt,name=dispatcherInfo,proto3" json:"dispatcherInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*EvhubMsg) Descriptor deprecated 

func (*EvhubMsg) Descriptor() ([]byte, []int)

Deprecated: Use EvhubMsg.ProtoReflect.Descriptor instead.

func (*EvhubMsg) GetDispatcherInfo 

func (x *EvhubMsg) GetDispatcherInfo() *EventDispatcherInfo

func (*EvhubMsg) GetEvent 

func (x *EvhubMsg) GetEvent() *Event

func (*EvhubMsg) GetEventId 

func (x *EvhubMsg) GetEventId() string

func (*EvhubMsg) GetStatus 

func (x *EvhubMsg) GetStatus() EventStatus

func (*EvhubMsg) GetTriggerInfo 

func (x *EvhubMsg) GetTriggerInfo() *EventTriggerInfo

func (*EvhubMsg) ProtoMessage 

func (*EvhubMsg) ProtoMessage()

func (*EvhubMsg) ProtoReflect 

func (x *EvhubMsg) ProtoReflect() protoreflect.Message

func (*EvhubMsg) Reset 

func (x *EvhubMsg) Reset()

func (*EvhubMsg) String 

func (x *EvhubMsg) String() string

type ProtocolType 

type ProtocolType int32
const (
	ProtocolType_PROTOCOL_TYPE_INVALID   ProtocolType = 0
	ProtocolType_PROTOCOL_TYPE_GRPC      ProtocolType = 1
	ProtocolType_PROTOCOL_TYPE_HTTP_PB   ProtocolType = 3
	ProtocolType_PROTOCOL_TYPE_HTTP_JSON ProtocolType = 5
)

func (ProtocolType) Descriptor 

func (ProtocolType) Descriptor() protoreflect.EnumDescriptor

func (ProtocolType) Enum 

func (x ProtocolType) Enum() *ProtocolType

func (ProtocolType) EnumDescriptor deprecated 

func (ProtocolType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ProtocolType.Descriptor instead.

func (ProtocolType) Number 

func (x ProtocolType) Number() protoreflect.EnumNumber

func (ProtocolType) String 

func (x ProtocolType) String() string

func (ProtocolType) Type 

func (ProtocolType) Type() protoreflect.EnumType

type RegularPulser 

type RegularPulser struct {
	Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*RegularPulser) Descriptor deprecated 

func (*RegularPulser) Descriptor() ([]byte, []int)

Deprecated: Use RegularPulser.ProtoReflect.Descriptor instead.

func (*RegularPulser) GetInterval 

func (x *RegularPulser) GetInterval() *duration.Duration

func (*RegularPulser) ProtoMessage 

func (*RegularPulser) ProtoMessage()

func (*RegularPulser) ProtoReflect 

func (x *RegularPulser) ProtoReflect() protoreflect.Message

func (*RegularPulser) Reset 

func (x *RegularPulser) Reset()

func (*RegularPulser) String 

func (x *RegularPulser) String() string

type RepeatEnd 

type RepeatEnd struct {
	RepeatTimes uint32               `protobuf:"varint,1,opt,name=repeat_times,json=repeatTimes,proto3" json:"repeat_times,omitempty"`
	EndTime     *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*RepeatEnd) Descriptor deprecated 

func (*RepeatEnd) Descriptor() ([]byte, []int)

Deprecated: Use RepeatEnd.ProtoReflect.Descriptor instead.

func (*RepeatEnd) GetEndTime 

func (x *RepeatEnd) GetEndTime() *timestamp.Timestamp

func (*RepeatEnd) GetRepeatTimes 

func (x *RepeatEnd) GetRepeatTimes() uint32

func (*RepeatEnd) ProtoMessage 

func (*RepeatEnd) ProtoMessage()

func (*RepeatEnd) ProtoReflect 

func (x *RepeatEnd) ProtoReflect() protoreflect.Message

func (*RepeatEnd) Reset 

func (x *RepeatEnd) Reset()

func (*RepeatEnd) String 

func (x *RepeatEnd) String() string

type Result 

type Result struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*Result) Descriptor deprecated 

func (*Result) Descriptor() ([]byte, []int)

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetCode 

func (x *Result) GetCode() int32

func (*Result) GetMsg 

func (x *Result) GetMsg() string

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

func (x *Result) ProtoReflect() protoreflect.Message

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

type Tx 

type Tx struct {
	EventId string   `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Status  TxStatus `protobuf:"varint,2,opt,name=status,proto3,enum=evhub_comm.TxStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Tx) Descriptor deprecated 

func (*Tx) Descriptor() ([]byte, []int)

Deprecated: Use Tx.ProtoReflect.Descriptor instead.

func (*Tx) GetEventId 

func (x *Tx) GetEventId() string

func (*Tx) GetStatus 

func (x *Tx) GetStatus() TxStatus

func (*Tx) ProtoMessage 

func (*Tx) ProtoMessage()

func (*Tx) ProtoReflect 

func (x *Tx) ProtoReflect() protoreflect.Message

func (*Tx) Reset 

func (x *Tx) Reset()

func (*Tx) String 

func (x *Tx) String() string

type TxCallback 

type TxCallback struct {
	Endpoint         *Endpoint          `protobuf:"bytes,1,opt,name=Endpoint,proto3" json:"Endpoint,omitempty"`
	CallbackInterval *duration.Duration `protobuf:"bytes,2,opt,name=callback_interval,json=callbackInterval,proto3" json:"callback_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*TxCallback) Descriptor deprecated 

func (*TxCallback) Descriptor() ([]byte, []int)

Deprecated: Use TxCallback.ProtoReflect.Descriptor instead.

func (*TxCallback) GetCallbackInterval 

func (x *TxCallback) GetCallbackInterval() *duration.Duration

func (*TxCallback) GetEndpoint 

func (x *TxCallback) GetEndpoint() *Endpoint

func (*TxCallback) ProtoMessage 

func (*TxCallback) ProtoMessage()

func (*TxCallback) ProtoReflect 

func (x *TxCallback) ProtoReflect() protoreflect.Message

func (*TxCallback) Reset 

func (x *TxCallback) Reset()

func (*TxCallback) String 

func (x *TxCallback) String() string

type TxStatus 

type TxStatus int32
const (
	TxStatus_TX_STATUS_INVALID  TxStatus = 0
	TxStatus_TX_STATUS_PREPARE  TxStatus = 1
	TxStatus_TX_STATUS_COMMIT   TxStatus = 2
	TxStatus_TX_STATUS_ROLLBACK TxStatus = 3
	TxStatus_TX_STATUS_SUCCESS  TxStatus = 4
)

func (TxStatus) Descriptor 

func (TxStatus) Descriptor() protoreflect.EnumDescriptor

func (TxStatus) Enum 

func (x TxStatus) Enum() *TxStatus

func (TxStatus) EnumDescriptor deprecated 

func (TxStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TxStatus.Descriptor instead.

func (TxStatus) Number 

func (x TxStatus) Number() protoreflect.EnumNumber

func (TxStatus) String 

func (x TxStatus) String() string

func (TxStatus) Type 

func (TxStatus) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.