pb

package
v0.0.0-...-c4618b4 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NodeEventResp_StatusCode_name = map[int32]string{
		0:  "SUCCESS",
		-1: "FAILURE",
	}
	NodeEventResp_StatusCode_value = map[string]int32{
		"SUCCESS": 0,
		"FAILURE": -1,
	}
)

Enum value maps for NodeEventResp_StatusCode.

View Source 
var File_node_event_proto protoreflect.FileDescriptor

Functions

func RegisterNodeEventServer 

func RegisterNodeEventServer(s *grpc.Server, srv NodeEventServer)

Types

type NodeEventClient 

type NodeEventClient interface {
	Event(ctx context.Context, in *NodeEventReq, opts ...grpc.CallOption) (*NodeEventResp, error)
}

NodeEventClient is the client API for NodeEvent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNodeEventClient 

func NewNodeEventClient(cc grpc.ClientConnInterface) NodeEventClient

type NodeEventReq 

type NodeEventReq struct {
	EventType string            `protobuf:"bytes,1,opt,name=eventType,proto3" json:"eventType,omitempty"` // nodeInitBeginEvent,nodeInitEndEvent,complete
	Data      *NodeEventReqData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The request message

func (*NodeEventReq) Descriptor deprecated 

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

Deprecated: Use NodeEventReq.ProtoReflect.Descriptor instead.

func (*NodeEventReq) GetData 

func (x *NodeEventReq) GetData() *NodeEventReqData

func (*NodeEventReq) GetEventType 

func (x *NodeEventReq) GetEventType() string

func (*NodeEventReq) ProtoMessage 

func (*NodeEventReq) ProtoMessage()

func (*NodeEventReq) ProtoReflect 

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

func (*NodeEventReq) Reset 

func (x *NodeEventReq) Reset()

func (*NodeEventReq) String 

func (x *NodeEventReq) String() string

type NodeEventReqData 

type NodeEventReqData struct {
	ProcessID         string   `protobuf:"bytes,1,opt,name=processID,proto3" json:"processID,omitempty"`
	ProcessInstanceID string   `protobuf:"bytes,2,opt,name=processInstanceID,proto3" json:"processInstanceID,omitempty"`
	ExecutionID       string   `protobuf:"bytes,3,opt,name=executionID,proto3" json:"executionID,omitempty"`
	NodeDefKey        string   `protobuf:"bytes,4,opt,name=nodeDefKey,proto3" json:"nodeDefKey,omitempty"`
	NodeInstanceID    string   `protobuf:"bytes,5,opt,name=nodeInstanceID,proto3" json:"nodeInstanceID,omitempty"`
	TaskID            []string `protobuf:"bytes,6,rep,name=taskID,proto3" json:"taskID,omitempty"` // 节点初始化结束事件才返回：或签一个task，会签多个taskID
	// contains filtered or unexported fields
}

func (*NodeEventReqData) Descriptor deprecated 

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

Deprecated: Use NodeEventReqData.ProtoReflect.Descriptor instead.

func (*NodeEventReqData) GetExecutionID 

func (x *NodeEventReqData) GetExecutionID() string

func (*NodeEventReqData) GetNodeDefKey 

func (x *NodeEventReqData) GetNodeDefKey() string

func (*NodeEventReqData) GetNodeInstanceID 

func (x *NodeEventReqData) GetNodeInstanceID() string

func (*NodeEventReqData) GetProcessID 

func (x *NodeEventReqData) GetProcessID() string

func (*NodeEventReqData) GetProcessInstanceID 

func (x *NodeEventReqData) GetProcessInstanceID() string

func (*NodeEventReqData) GetTaskID 

func (x *NodeEventReqData) GetTaskID() []string

func (*NodeEventReqData) ProtoMessage 

func (*NodeEventReqData) ProtoMessage()

func (*NodeEventReqData) ProtoReflect 

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

func (*NodeEventReqData) Reset 

func (x *NodeEventReqData) Reset()

func (*NodeEventReqData) String 

func (x *NodeEventReqData) String() string

type NodeEventResp 

type NodeEventResp struct {
	Code NodeEventResp_StatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=proto.NodeEventResp_StatusCode" json:"code,omitempty"`
	Msg  string                   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Data *NodeEventRespData       `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The response message

func (*NodeEventResp) Descriptor deprecated 

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

Deprecated: Use NodeEventResp.ProtoReflect.Descriptor instead.

func (*NodeEventResp) GetCode 

func (x *NodeEventResp) GetCode() NodeEventResp_StatusCode

func (*NodeEventResp) GetData 

func (x *NodeEventResp) GetData() *NodeEventRespData

func (*NodeEventResp) GetMsg 

func (x *NodeEventResp) GetMsg() string

func (*NodeEventResp) ProtoMessage 

func (*NodeEventResp) ProtoMessage()

func (*NodeEventResp) ProtoReflect 

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

func (*NodeEventResp) Reset 

func (x *NodeEventResp) Reset()

func (*NodeEventResp) String 

func (x *NodeEventResp) String() string

type NodeEventRespData 

type NodeEventRespData struct {
	Assignee    []string `protobuf:"bytes,1,rep,name=assignee,proto3" json:"assignee,omitempty"`       // 节点初始化开始事件才关注：节点处理人
	ExecuteType string   `protobuf:"bytes,2,opt,name=executeType,proto3" json:"executeType,omitempty"` // 节点初始化结束事件才关注，执行类型：pauseExecution，endExecution，endProcess
	Comments    string   `protobuf:"bytes,3,opt,name=comments,proto3" json:"comments,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeEventRespData) Descriptor deprecated 

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

Deprecated: Use NodeEventRespData.ProtoReflect.Descriptor instead.

func (*NodeEventRespData) GetAssignee 

func (x *NodeEventRespData) GetAssignee() []string

func (*NodeEventRespData) GetComments 

func (x *NodeEventRespData) GetComments() string

func (*NodeEventRespData) GetExecuteType 

func (x *NodeEventRespData) GetExecuteType() string

func (*NodeEventRespData) ProtoMessage 

func (*NodeEventRespData) ProtoMessage()

func (*NodeEventRespData) ProtoReflect 

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

func (*NodeEventRespData) Reset 

func (x *NodeEventRespData) Reset()

func (*NodeEventRespData) String 

func (x *NodeEventRespData) String() string

type NodeEventResp_StatusCode 

type NodeEventResp_StatusCode int32
const (
	NodeEventResp_SUCCESS NodeEventResp_StatusCode = 0
	NodeEventResp_FAILURE NodeEventResp_StatusCode = -1
)

func (NodeEventResp_StatusCode) Descriptor 

func (NodeEventResp_StatusCode) Descriptor() protoreflect.EnumDescriptor

func (NodeEventResp_StatusCode) Enum 

func (x NodeEventResp_StatusCode) Enum() *NodeEventResp_StatusCode

func (NodeEventResp_StatusCode) EnumDescriptor deprecated 

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

Deprecated: Use NodeEventResp_StatusCode.Descriptor instead.

func (NodeEventResp_StatusCode) Number 

func (x NodeEventResp_StatusCode) Number() protoreflect.EnumNumber

func (NodeEventResp_StatusCode) String 

func (x NodeEventResp_StatusCode) String() string

func (NodeEventResp_StatusCode) Type 

func (NodeEventResp_StatusCode) Type() protoreflect.EnumType

type NodeEventServer 

type NodeEventServer interface {
	Event(context.Context, *NodeEventReq) (*NodeEventResp, error)
}

NodeEventServer is the server API for NodeEvent service.

type UnimplementedNodeEventServer 

type UnimplementedNodeEventServer struct {
}

UnimplementedNodeEventServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeEventServer) Event 

func (*UnimplementedNodeEventServer) Event(context.Context, *NodeEventReq) (*NodeEventResp, error)

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.