trailer

type AppManifest struct {
	Native     bool     `json:"native"`
	ScriptHost string   `json:"scripthost"`
	Executable string   `json:"executable"`
	Env        []string `json:"env"`
}

type Column struct {
	Name        string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        ValueType `protobuf:"varint,2,opt,name=type,proto3,enum=trailer.ValueType" json:"type,omitempty"`
	Description string    `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type ColumnValue struct {
	Name  string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type  ValueType `protobuf:"varint,2,opt,name=type,proto3,enum=trailer.ValueType" json:"type,omitempty"`
	Id    string    `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Value []byte    `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Config struct {
	Kv []byte `protobuf:"bytes,1,opt,name=kv,proto3" json:"kv,omitempty"`
	// contains filtered or unexported fields
}

type DataRow struct {
	Column []*ColumnValue `protobuf:"bytes,1,rep,name=column,proto3" json:"column,omitempty"` // 一行多列
	// contains filtered or unexported fields
}

type DataRowsRequest struct {
	Query []byte `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // SQL or other query
	// contains filtered or unexported fields
}

type DataRowsResponse struct {
	Row []*DataRow `protobuf:"bytes,1,rep,name=row,proto3" json:"row,omitempty"` // 多行
	// contains filtered or unexported fields
}

type GoodsInfo struct {
	UUID        string `json:"uuid"`
	Name        string `json:"name"`         // 进程名
	GoodsType   string `json:"goods_type"`   // LOCAL(RULEX原始设备), EXTERNAL（外部RPC设备）
	ExecuteType string `json:"execute_type"` // exe,elf,jar,py, nodejs....
	AutoStart   *bool  `json:"auto_start"`   // 是否开启自启动，目前全部是自启动
	LocalPath   string `json:"local_path"`   // TCP or Unix Socket
	NetAddr     string `json:"net_addr"`     // RPC addr
	Description string `json:"description"`  // Description text
	// Additional Args
	Args     string `json:"args"` // 使用空格分割 , such: la -al
	KilledBy string // 进程被谁干死的, 一般用来处理要不要抢救进程
}

type GoodsProcess struct {
	Info GoodsInfo
	// contains filtered or unexported fields
}

type ProcessInfo struct {
	CPU     string `json:"cpu"`
	Memory  string `json:"memory"`
	VSZ     string `json:"vsz"`
	RSS     string `json:"rss"`
	TTY     string `json:"tty"`
	Stat    string `json:"stat"`
	Start   string `json:"start"`
	Time    string `json:"time"`
	Command string `json:"command"`
}

type Request struct {
	// contains filtered or unexported fields
}

type Response struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type SchemaRequest struct {
	// contains filtered or unexported fields
}

type SchemaResponse struct {
	Code    int32     `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Columns []*Column `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

type ServiceRequest struct {
	Cmd  []byte `protobuf:"bytes,1,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Args []byte `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type ServiceResponse struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type StatusResponse struct {
	Status  StatusResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=trailer.StatusResponse_Status" json:"status,omitempty"`
	Message string                `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type StatusResponse_Status int32

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

type StreamResponse struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type TrailerClient interface {
	// 初始化, 主要是为了传配置进去
	Init(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Response, error)
	// 启动
	Start(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// 获取状态
	Status(ctx context.Context, in *Request, opts ...grpc.CallOption) (*StatusResponse, error)
	// 服务调用
	Service(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ServiceResponse, error)
	// 流数据
	OnStream(ctx context.Context, opts ...grpc.CallOption) (Trailer_OnStreamClient, error)
	// 数据查询
	Query(ctx context.Context, in *DataRowsRequest, opts ...grpc.CallOption) (*DataRowsResponse, error)
	// 数据模型
	Schema(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaResponse, error)
	// 停止
	Stop(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

type TrailerRuntime struct {
	// contains filtered or unexported fields
}

type TrailerServer interface {
	// 初始化, 主要是为了传配置进去
	Init(context.Context, *Config) (*Response, error)
	// 启动
	Start(context.Context, *Request) (*Response, error)
	// 获取状态
	Status(context.Context, *Request) (*StatusResponse, error)
	// 服务调用
	Service(context.Context, *ServiceRequest) (*ServiceResponse, error)
	// 流数据
	OnStream(Trailer_OnStreamServer) error
	// 数据查询
	Query(context.Context, *DataRowsRequest) (*DataRowsResponse, error)
	// 数据模型
	Schema(context.Context, *SchemaRequest) (*SchemaResponse, error)
	// 停止
	Stop(context.Context, *Request) (*Response, error)
	// contains filtered or unexported methods
}

type Trailer_OnStreamClient interface {
	Send(*StreamRequest) error
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type Trailer_OnStreamServer interface {
	Send(*StreamResponse) error
	Recv() (*StreamRequest, error)
	grpc.ServerStream
}

type UnimplementedTrailerServer struct {
}

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

type ValueType int32