comm

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

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

type EventPulserType int32

type EventRepeatEndType int32

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
}

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
}

type EventStatus int32

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
}

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
}

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
}

type EventTriggerType int32

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
}

type ProtocolType int32

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

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
}

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
}

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
}

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
}

type TxStatus int32