api

package

Go to main page

Versions in this module

v1

v1.0.3

Jul 28, 2023

Changes in this version

+ var File_grpc_api_aline_proto protoreflect.FileDescriptor

+ var JobStatus_name = map[int32]string

+ var JobStatus_value = map[string]int32

+ var MessageType_name = map[int32]string

+ var MessageType_value = map[string]int32

type AlineMessage

+ Error string

+ File *File

+ Name string

+ Status JobStatus

+ func (x *AlineMessage) GetError() string

+ func (x *AlineMessage) GetFile() *File

+ func (x *AlineMessage) GetName() string

+ func (x *AlineMessage) GetStatus() JobStatus

type ExecuteReq

+ Name string

+ func (x *ExecuteReq) GetName() string

type ExecuteResult

+ Error string

+ JobID int64

+ JobName string

+ JobStatus int64

+ func (x *ExecuteResult) GetError() string

+ func (x *ExecuteResult) GetJobID() int64

+ func (x *ExecuteResult) GetJobName() string

+ func (x *ExecuteResult) GetJobStatus() int64

+ type File struct

+ Data []byte

+ Path string

+ func (*File) Descriptor() ([]byte, []int)

+ func (*File) ProtoMessage()

+ func (x *File) GetData() []byte

+ func (x *File) GetPath() string

+ func (x *File) ProtoReflect() protoreflect.Message

+ func (x *File) Reset()

+ func (x *File) String() string

+ type JobStatus int32

+ const JobStatus_FAIL

+ const JobStatus_NOTRUN

+ const JobStatus_RUNNING

+ const JobStatus_STOP

+ const JobStatus_SUCCESS

+ func (JobStatus) Descriptor() protoreflect.EnumDescriptor

+ func (JobStatus) EnumDescriptor() ([]byte, []int)

+ func (JobStatus) Type() protoreflect.EnumType

+ func (x JobStatus) Enum() *JobStatus

+ func (x JobStatus) Number() protoreflect.EnumNumber

+ func (x JobStatus) String() string

+ type MessageType int32

+ const MessageType_CANCEL

+ const MessageType_ERROR

+ const MessageType_EXECUTE

+ const MessageType_FILE

+ const MessageType_HEARTBEAT

+ const MessageType_LOG

+ const MessageType_REGISTER

+ const MessageType_RESULT

+ const MessageType_STATUS

+ const MessageType_UNREGISTER

+ func (MessageType) Descriptor() protoreflect.EnumDescriptor

+ func (MessageType) EnumDescriptor() ([]byte, []int)

+ func (MessageType) Type() protoreflect.EnumType

+ func (x MessageType) Enum() *MessageType

+ func (x MessageType) Number() protoreflect.EnumNumber

+ func (x MessageType) String() string

v1.0.2

Feb 1, 2023

v1.0.1

Jan 29, 2023

v1.0.0

Jan 29, 2023

Changes in this version

+ var AlineRPC_ServiceDesc = grpc.ServiceDesc

+ var File_pkg_grpc_api_aline_proto protoreflect.FileDescriptor

+ func RegisterAlineRPCServer(s grpc.ServiceRegistrar, srv AlineRPCServer)

+ type AlineMessage struct

+ Address string

+ ExecReq *ExecuteReq

+ Log *Log

+ Result string

+ Type int64

+ func (*AlineMessage) Descriptor() ([]byte, []int)

+ func (*AlineMessage) ProtoMessage()

+ func (x *AlineMessage) GetAddress() string

+ func (x *AlineMessage) GetExecReq() *ExecuteReq

+ func (x *AlineMessage) GetLog() *Log

+ func (x *AlineMessage) GetResult() string

+ func (x *AlineMessage) GetType() int64

+ func (x *AlineMessage) ProtoReflect() protoreflect.Message

+ func (x *AlineMessage) Reset()

+ func (x *AlineMessage) String() string

+ type AlineRPCClient interface

+ AlineChat func(ctx context.Context, opts ...grpc.CallOption) (AlineRPC_AlineChatClient, error)

+ func NewAlineRPCClient(cc grpc.ClientConnInterface) AlineRPCClient

+ type AlineRPCServer interface

+ AlineChat func(AlineRPC_AlineChatServer) error

+ type AlineRPC_AlineChatClient interface

+ Recv func() (*AlineMessage, error)

+ Send func(*AlineMessage) error

+ type AlineRPC_AlineChatServer interface

+ Recv func() (*AlineMessage, error)

+ Send func(*AlineMessage) error

+ type ExecuteReq struct

+ JobDetailId int64

+ PipelineFile string

+ func (*ExecuteReq) Descriptor() ([]byte, []int)

+ func (*ExecuteReq) ProtoMessage()

+ func (x *ExecuteReq) GetJobDetailId() int64

+ func (x *ExecuteReq) GetPipelineFile() string

+ func (x *ExecuteReq) ProtoReflect() protoreflect.Message

+ func (x *ExecuteReq) Reset()

+ func (x *ExecuteReq) String() string

+ type ExecuteResult struct

+ Duration int64

+ JobDetail string

+ StartTime string

+ func (*ExecuteResult) Descriptor() ([]byte, []int)

+ func (*ExecuteResult) ProtoMessage()

+ func (x *ExecuteResult) GetDuration() int64

+ func (x *ExecuteResult) GetJobDetail() string

+ func (x *ExecuteResult) GetStartTime() string

+ func (x *ExecuteResult) ProtoReflect() protoreflect.Message

+ func (x *ExecuteResult) Reset()

+ func (x *ExecuteResult) String() string

+ type Log struct

+ Content string

+ More bool

+ Stage string

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

+ func (x *Log) GetContent() string

+ func (x *Log) GetMore() bool

+ func (x *Log) GetStage() string

+ func (x *Log) ProtoReflect() protoreflect.Message

+ func (x *Log) Reset()

+ func (x *Log) String() string

+ type UnimplementedAlineRPCServer struct

+ func (UnimplementedAlineRPCServer) AlineChat(AlineRPC_AlineChatServer) error

+ type UnsafeAlineRPCServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL