api

type AlineMessage struct {

	// 1: register 2: offline 3: heartbeat  4: execute 5: cancel 6: executeResultNotify 7: getLog
	Type int64 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	// registry
	Address string      `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	ExecReq *ExecuteReq `protobuf:"bytes,3,opt,name=execReq,proto3" json:"execReq,omitempty"`
	// execute result
	Result string `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	// log
	Log *Log `protobuf:"bytes,5,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

type AlineRPCClient interface {
	AlineChat(ctx context.Context, opts ...grpc.CallOption) (AlineRPC_AlineChatClient, error)
}

type AlineRPCServer interface {
	AlineChat(AlineRPC_AlineChatServer) error
	// contains filtered or unexported methods
}

type AlineRPC_AlineChatClient interface {
	Send(*AlineMessage) error
	Recv() (*AlineMessage, error)
	grpc.ClientStream
}

type AlineRPC_AlineChatServer interface {
	Send(*AlineMessage) error
	Recv() (*AlineMessage, error)
	grpc.ServerStream
}

type ExecuteReq struct {

	// pipeline file
	PipelineFile string `protobuf:"bytes,1,opt,name=pipelineFile,proto3" json:"pipelineFile,omitempty"`
	// job exec id
	JobDetailId int64 `protobuf:"varint,2,opt,name=jobDetailId,proto3" json:"jobDetailId,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResult struct {
	JobDetail string `protobuf:"bytes,1,opt,name=jobDetail,proto3" json:"jobDetail,omitempty"`
	StartTime string `protobuf:"bytes,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	Duration  int64  `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

type Log struct {
	Stage   string `protobuf:"bytes,1,opt,name=stage,proto3" json:"stage,omitempty"`
	Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	More    bool   `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAlineRPCServer struct {
}

type UnsafeAlineRPCServer interface {
	// contains filtered or unexported methods
}