workflowpb

Documentation

Index

• Variables
• func ProtoMarshal(r *workflow.Record) ([]byte, error)
• func UnmarshalRecord(b []byte) (*workflow.Record, error)
• type Record
  • func ToProto(r *workflow.Record) *Record
  • func (*Record) Descriptor() ([]byte, []int)
  • func (x *Record) GetCreatedAt() *timestamppb.Timestamp
  • func (x *Record) GetForeignId() string
  • func (x *Record) GetId() int64
  • func (x *Record) GetIsEnd() bool
  • func (x *Record) GetIsStart() bool
  • func (x *Record) GetObject() []byte
  • func (x *Record) GetRunId() string
  • func (x *Record) GetRunState() int32
  • func (x *Record) GetStatus() int32
  • func (x *Record) GetUpdatedAt() *timestamppb.Timestamp
  • func (x *Record) GetWorkflowName() string
  • func (*Record) ProtoMessage()
  • func (x *Record) ProtoReflect() protoreflect.Message
  • func (x *Record) Reset()
  • func (x *Record) String() string

Variables

var File_workflow_proto protoreflect.FileDescriptor

Functions

func ProtoMarshal

func ProtoMarshal(r *workflow.Record) ([]byte, error)

func UnmarshalRecord

func UnmarshalRecord(b []byte) (*workflow.Record, error)

Types

type Record

type Record struct {
	Id           int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	RunId        string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	WorkflowName string `protobuf:"bytes,3,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	ForeignId    string `protobuf:"bytes,4,opt,name=foreign_id,json=foreignId,proto3" json:"foreign_id,omitempty"`
	// Deprecated: Marked as deprecated in workflow.proto.
	IsStart bool `protobuf:"varint,5,opt,name=is_start,json=isStart,proto3" json:"is_start,omitempty"` // Use RunState
	// Deprecated: Marked as deprecated in workflow.proto.
	IsEnd     bool                   `protobuf:"varint,6,opt,name=is_end,json=isEnd,proto3" json:"is_end,omitempty"` // Use RunState
	Object    []byte                 `protobuf:"bytes,7,opt,name=object,proto3" json:"object,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Status    int32                  `protobuf:"varint,9,opt,name=status,proto3" json:"status,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	RunState  int32                  `protobuf:"varint,11,opt,name=run_state,json=runState,proto3" json:"run_state,omitempty"`
	// contains filtered or unexported fields
}

func ToProto

func ToProto(r *workflow.Record) *Record

func (*Record) Descriptor

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetCreatedAt

func (x *Record) GetCreatedAt() *timestamppb.Timestamp

func (*Record) GetForeignId

func (x *Record) GetForeignId() string

func (*Record) GetId

func (x *Record) GetId() int64

func (*Record) GetIsEnd

func (x *Record) GetIsEnd() bool

Deprecated: Marked as deprecated in workflow.proto.

func (*Record) GetIsStart

func (x *Record) GetIsStart() bool

Deprecated: Marked as deprecated in workflow.proto.

func (*Record) GetObject

func (x *Record) GetObject() []byte

func (*Record) GetRunId

func (x *Record) GetRunId() string

func (*Record) GetRunState

func (x *Record) GetRunState() int32

func (*Record) GetStatus

func (x *Record) GetStatus() int32

func (*Record) GetUpdatedAt

func (x *Record) GetUpdatedAt() *timestamppb.Timestamp

func (*Record) GetWorkflowName

func (x *Record) GetWorkflowName() string

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect

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

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string