protos

Documentation

Index

• Variables
• type DataRow
  • func (*DataRow) Descriptor() ([]byte, []int)
  • func (x *DataRow) GetData() []string
  • func (*DataRow) ProtoMessage()
  • func (x *DataRow) ProtoReflect() protoreflect.Message
  • func (x *DataRow) Reset()
  • func (x *DataRow) String() string
• type HCReq
  • func (*HCReq) Descriptor() ([]byte, []int)
  • func (x *HCReq) GetUuid() string
  • func (*HCReq) ProtoMessage()
  • func (x *HCReq) ProtoReflect() protoreflect.Message
  • func (x *HCReq) Reset()
  • func (x *HCReq) String() string
• type HCRes
  • func (*HCRes) Descriptor() ([]byte, []int)
  • func (x *HCRes) GetTime() *timestamp.Timestamp
  • func (x *HCRes) GetUuid() string
  • func (*HCRes) ProtoMessage()
  • func (x *HCRes) ProtoReflect() protoreflect.Message
  • func (x *HCRes) Reset()
  • func (x *HCRes) String() string
• type RegisterReq
  • func (*RegisterReq) Descriptor() ([]byte, []int)
  • func (x *RegisterReq) GetHttp() string
  • func (x *RegisterReq) GetUuid() string
  • func (*RegisterReq) ProtoMessage()
  • func (x *RegisterReq) ProtoReflect() protoreflect.Message
  • func (x *RegisterReq) Reset()
  • func (x *RegisterReq) String() string
• type RegisterRes
  • func (*RegisterRes) Descriptor() ([]byte, []int)
  • func (x *RegisterRes) GetOk() bool
  • func (*RegisterRes) ProtoMessage()
  • func (x *RegisterRes) ProtoReflect() protoreflect.Message
  • func (x *RegisterRes) Reset()
  • func (x *RegisterRes) String() string
• type Task
  • func (*Task) Descriptor() ([]byte, []int)
  • func (x *Task) GetCreationTime() *timestamp.Timestamp
  • func (x *Task) GetDagId() string
  • func (x *Task) GetInstactions() []string
  • func (x *Task) GetPlugin() string
  • func (x *Task) GetUuid() string
  • func (*Task) ProtoMessage()
  • func (x *Task) ProtoReflect() protoreflect.Message
  • func (x *Task) Reset()
  • func (x *Task) String() string
• type TaskResult
  • func (*TaskResult) Descriptor() ([]byte, []int)
  • func (x *TaskResult) GetData() []*DataRow
  • func (x *TaskResult) GetDataflow() bool
  • func (x *TaskResult) GetEndTime() *timestamp.Timestamp
  • func (x *TaskResult) GetStatus() bool
  • func (x *TaskResult) GetUuid() string
  • func (*TaskResult) ProtoMessage()
  • func (x *TaskResult) ProtoReflect() protoreflect.Message
  • func (x *TaskResult) Reset()
  • func (x *TaskResult) String() string

Variables

var File_protos_mw_proto protoreflect.FileDescriptor

var File_protos_task_proto protoreflect.FileDescriptor

Types

type DataRow

type DataRow struct {
	Data []string `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*DataRow) Descriptor

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

Deprecated: Use DataRow.ProtoReflect.Descriptor instead.

func (*DataRow) GetData

func (x *DataRow) GetData() []string

func (*DataRow) ProtoMessage

func (*DataRow) ProtoMessage()

func (*DataRow) ProtoReflect

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

func (*DataRow) Reset

func (x *DataRow) Reset()

func (*DataRow) String

func (x *DataRow) String() string

type HCReq

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

func (*HCReq) Descriptor

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

Deprecated: Use HCReq.ProtoReflect.Descriptor instead.

func (*HCReq) GetUuid

func (x *HCReq) GetUuid() string

func (*HCReq) ProtoMessage

func (*HCReq) ProtoMessage()

func (*HCReq) ProtoReflect

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

func (*HCReq) Reset

func (x *HCReq) Reset()

func (*HCReq) String

func (x *HCReq) String() string

type HCRes

type HCRes struct {
	Uuid string               `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Time *timestamp.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*HCRes) Descriptor

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

Deprecated: Use HCRes.ProtoReflect.Descriptor instead.

func (*HCRes) GetTime

func (x *HCRes) GetTime() *timestamp.Timestamp

func (*HCRes) GetUuid

func (x *HCRes) GetUuid() string

func (*HCRes) ProtoMessage

func (*HCRes) ProtoMessage()

func (*HCRes) ProtoReflect

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

func (*HCRes) Reset

func (x *HCRes) Reset()

func (*HCRes) String

func (x *HCRes) String() string

type RegisterReq

type RegisterReq struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Http string `protobuf:"bytes,2,opt,name=http,proto3" json:"http,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterReq) Descriptor

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

Deprecated: Use RegisterReq.ProtoReflect.Descriptor instead.

func (*RegisterReq) GetHttp

func (x *RegisterReq) GetHttp() string

func (*RegisterReq) GetUuid

func (x *RegisterReq) GetUuid() string

func (*RegisterReq) ProtoMessage

func (*RegisterReq) ProtoMessage()

func (*RegisterReq) ProtoReflect

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

func (*RegisterReq) Reset

func (x *RegisterReq) Reset()

func (*RegisterReq) String

func (x *RegisterReq) String() string

type RegisterRes

type RegisterRes struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRes) Descriptor

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

Deprecated: Use RegisterRes.ProtoReflect.Descriptor instead.

func (*RegisterRes) GetOk

func (x *RegisterRes) GetOk() bool

func (*RegisterRes) ProtoMessage

func (*RegisterRes) ProtoMessage()

func (*RegisterRes) ProtoReflect

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

func (*RegisterRes) Reset

func (x *RegisterRes) Reset()

func (*RegisterRes) String

func (x *RegisterRes) String() string

type Task

type Task struct {
	Uuid         string               `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Plugin       string               `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Instactions  []string             `protobuf:"bytes,3,rep,name=instactions,proto3" json:"instactions,omitempty"`
	CreationTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=creationTime,proto3" json:"creationTime,omitempty"`
	DagId        string               `protobuf:"bytes,5,opt,name=dagId,proto3" json:"dagId,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreationTime

func (x *Task) GetCreationTime() *timestamp.Timestamp

func (*Task) GetDagId

func (x *Task) GetDagId() string

func (*Task) GetInstactions

func (x *Task) GetInstactions() []string

func (*Task) GetPlugin

func (x *Task) GetPlugin() string

func (*Task) GetUuid

func (x *Task) GetUuid() string

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

type TaskResult

type TaskResult struct {
	Uuid     string               `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Status   bool                 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Dataflow bool                 `protobuf:"varint,3,opt,name=dataflow,proto3" json:"dataflow,omitempty"`
	Data     []*DataRow           `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
	EndTime  *timestamp.Timestamp `protobuf:"bytes,5,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResult) Descriptor

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

Deprecated: Use TaskResult.ProtoReflect.Descriptor instead.

func (*TaskResult) GetData

func (x *TaskResult) GetData() []*DataRow

func (*TaskResult) GetDataflow

func (x *TaskResult) GetDataflow() bool

func (*TaskResult) GetEndTime

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

func (*TaskResult) GetStatus

func (x *TaskResult) GetStatus() bool

func (*TaskResult) GetUuid

func (x *TaskResult) GetUuid() string

func (*TaskResult) ProtoMessage

func (*TaskResult) ProtoMessage()

func (*TaskResult) ProtoReflect

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

func (*TaskResult) Reset

func (x *TaskResult) Reset()

func (*TaskResult) String

func (x *TaskResult) String() string