Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

trailer

package

Go to main page

Versions in this module

v0

v0.6.7

Mar 15, 2024

v0.6.6

Feb 19, 2024

v0.6.5

Dec 30, 2023

v0.6.4

Nov 14, 2023

Changes in this version

+ const Trailer_Init_FullMethodName

+ const Trailer_OnStream_FullMethodName

+ const Trailer_Query_FullMethodName

+ const Trailer_Schema_FullMethodName

+ const Trailer_Service_FullMethodName

+ const Trailer_Start_FullMethodName

+ const Trailer_Status_FullMethodName

+ const Trailer_Stop_FullMethodName

+ var ExecuteType = map[string]string

+ var File_trailer_proto protoreflect.FileDescriptor

+ var StatusResponse_Status_name = map[int32]string

+ var StatusResponse_Status_value = map[string]int32

+ var Trailer_ServiceDesc = grpc.ServiceDesc

+ var ValueType_name = map[int32]string

+ var ValueType_value = map[string]int32

+ func AllGoods() *sync.Map

+ func CreateUnzipPath(dir string) error

+ func NewSysProcAttr() *syscall.SysProcAttr — linux/amd64, windows/amd64

+ func NewWSStdInOut(ps *GoodsProcess) goodsStdInOut

+ func RegisterTrailerServer(s grpc.ServiceRegistrar, srv TrailerServer)

+ func Remove(uuid string)

+ func RemoveBy(uuid, by string)

+ func RemoveUnzipPath(dir string) error

+ func StartProcess(goods GoodsInfo) error

+ func Stop()

+ func StopProcess(goods GoodsInfo) error

+ func Unzip(zipPath string, targetDir string) error

+ func ValidatePackage(mf AppManifest) error

+ func Zip(files []string, targetPath string) error

+ type AppManifest struct

+ Env []string

+ Executable string

+ Native bool

+ ScriptHost string

+ func ReadManifestFromZip(zipPath string, targetFile string) (AppManifest, error)

+ type Column struct

+ Description string

+ Name string

+ Type ValueType

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

+ func (*Column) ProtoMessage()

+ func (x *Column) GetDescription() string

+ func (x *Column) GetName() string

+ func (x *Column) GetType() ValueType

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

+ func (x *Column) Reset()

+ func (x *Column) String() string

+ type ColumnValue struct

+ Id string

+ Name string

+ Type ValueType

+ Value []byte

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

+ func (*ColumnValue) ProtoMessage()

+ func (x *ColumnValue) GetId() string

+ func (x *ColumnValue) GetName() string

+ func (x *ColumnValue) GetType() ValueType

+ func (x *ColumnValue) GetValue() []byte

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

+ func (x *ColumnValue) Reset()

+ func (x *ColumnValue) String() string

+ type Config struct

+ Kv []byte

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

+ func (*Config) ProtoMessage()

+ func (x *Config) GetKv() []byte

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

+ func (x *Config) Reset()

+ func (x *Config) String() string

+ type DataRow struct

+ Column []*ColumnValue

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

+ func (*DataRow) ProtoMessage()

+ func (x *DataRow) GetColumn() []*ColumnValue

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

+ func (x *DataRow) Reset()

+ func (x *DataRow) String() string

+ type DataRowsRequest struct

+ Query []byte

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

+ func (*DataRowsRequest) ProtoMessage()

+ func (x *DataRowsRequest) GetQuery() []byte

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

+ func (x *DataRowsRequest) Reset()

+ func (x *DataRowsRequest) String() string

+ type DataRowsResponse struct

+ Row []*DataRow

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

+ func (*DataRowsResponse) ProtoMessage()

+ func (x *DataRowsResponse) GetRow() []*DataRow

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

+ func (x *DataRowsResponse) Reset()

+ func (x *DataRowsResponse) String() string

+ type GoodsInfo struct

+ Args string

+ AutoStart *bool

+ Description string

+ ExecuteType string

+ GoodsType string

+ KilledBy string

+ LocalPath string

+ Name string

+ NetAddr string

+ UUID string

+ type GoodsProcess struct

+ Info GoodsInfo

+ func Get(uuid string) *GoodsProcess

+ func NewGoodsProcess() *GoodsProcess

+ func (g GoodsProcess) String() string

+ func (goodsProcess *GoodsProcess) ConnectToRpc() (TrailerClient, error)

+ func (goodsProcess *GoodsProcess) Pid() int

+ func (goodsProcess *GoodsProcess) PsRunning() bool

+ func (goodsPs *GoodsProcess) Stop()

+ func (goodsPs *GoodsProcess) StopBy(r string)

+ type ProcessInfo struct — linux/amd64, windows/amd64

+ CPU string

+ Command string

+ ImageName string

+ Memory string

+ PID string

+ RSS string

+ SessionName string

+ SessionNum string

+ Start string

+ Stat string

+ TTY string

+ Time string

+ VSZ string

+ func RunningProcessDetail(pid int) (ProcessInfo, error)

+ type Request struct

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

+ func (*Request) ProtoMessage()

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

+ func (x *Request) Reset()

+ func (x *Request) String() string

+ type Response struct

+ Code int32

+ Message string

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

+ func (*Response) ProtoMessage()

+ func (x *Response) GetCode() int32

+ func (x *Response) GetMessage() string

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

+ func (x *Response) Reset()

+ func (x *Response) String() string

+ type SchemaRequest struct

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

+ func (*SchemaRequest) ProtoMessage()

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

+ func (x *SchemaRequest) Reset()

+ func (x *SchemaRequest) String() string

+ type SchemaResponse struct

+ Code int32

+ Columns []*Column

+ Message string

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

+ func (*SchemaResponse) ProtoMessage()

+ func (x *SchemaResponse) GetCode() int32

+ func (x *SchemaResponse) GetColumns() []*Column

+ func (x *SchemaResponse) GetMessage() string

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

+ func (x *SchemaResponse) Reset()

+ func (x *SchemaResponse) String() string

+ type ServiceRequest struct

+ Args []byte

+ Cmd []byte

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

+ func (*ServiceRequest) ProtoMessage()

+ func (x *ServiceRequest) GetArgs() []byte

+ func (x *ServiceRequest) GetCmd() []byte

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

+ func (x *ServiceRequest) Reset()

+ func (x *ServiceRequest) String() string

+ type ServiceResponse struct

+ Code int32

+ Data []byte

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

+ func (*ServiceResponse) ProtoMessage()

+ func (x *ServiceResponse) GetCode() int32

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

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

+ func (x *ServiceResponse) Reset()

+ func (x *ServiceResponse) String() string

+ type StatusResponse struct

+ Message string

+ Status StatusResponse_Status

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

+ func (*StatusResponse) ProtoMessage()

+ func (x *StatusResponse) GetMessage() string

+ func (x *StatusResponse) GetStatus() StatusResponse_Status

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

+ func (x *StatusResponse) Reset()

+ func (x *StatusResponse) String() string

+ type StatusResponse_Status int32

+ const StatusResponse_ERROR

+ const StatusResponse_RUNNING

+ const StatusResponse_STOPED

+ func (StatusResponse_Status) Descriptor() protoreflect.EnumDescriptor

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

+ func (StatusResponse_Status) Type() protoreflect.EnumType

+ func (x StatusResponse_Status) Enum() *StatusResponse_Status

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

+ func (x StatusResponse_Status) String() string

+ type StreamRequest struct

+ Data []byte

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

+ func (*StreamRequest) ProtoMessage()

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

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

+ func (x *StreamRequest) Reset()

+ func (x *StreamRequest) String() string

+ type StreamResponse struct

+ Code int32

+ Data []byte

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

+ func (*StreamResponse) ProtoMessage()

+ func (x *StreamResponse) GetCode() int32

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

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

+ func (x *StreamResponse) Reset()

+ func (x *StreamResponse) String() string

+ type TrailerClient interface

+ Init func(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Response, error)

+ OnStream func(ctx context.Context, opts ...grpc.CallOption) (Trailer_OnStreamClient, error)

+ Query func(ctx context.Context, in *DataRowsRequest, opts ...grpc.CallOption) (*DataRowsResponse, error)

+ Schema func(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaResponse, error)

+ Service func(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ServiceResponse, error)

+ Start func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ Status func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*StatusResponse, error)

+ Stop func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ func NewTrailerClient(cc grpc.ClientConnInterface) TrailerClient

+ type TrailerRuntime struct

+ func InitTrailerRuntime(re typex.RuleX) *TrailerRuntime

+ type TrailerServer interface

+ Init func(context.Context, *Config) (*Response, error)

+ OnStream func(Trailer_OnStreamServer) error

+ Query func(context.Context, *DataRowsRequest) (*DataRowsResponse, error)

+ Schema func(context.Context, *SchemaRequest) (*SchemaResponse, error)

+ Service func(context.Context, *ServiceRequest) (*ServiceResponse, error)

+ Start func(context.Context, *Request) (*Response, error)

+ Status func(context.Context, *Request) (*StatusResponse, error)

+ Stop func(context.Context, *Request) (*Response, error)

+ type Trailer_OnStreamClient interface

+ Recv func() (*StreamResponse, error)

+ Send func(*StreamRequest) error

+ type Trailer_OnStreamServer interface

+ Recv func() (*StreamRequest, error)

+ Send func(*StreamResponse) error

+ type UnimplementedTrailerServer struct

+ func (UnimplementedTrailerServer) Init(context.Context, *Config) (*Response, error)

+ func (UnimplementedTrailerServer) OnStream(Trailer_OnStreamServer) error

+ func (UnimplementedTrailerServer) Query(context.Context, *DataRowsRequest) (*DataRowsResponse, error)

+ func (UnimplementedTrailerServer) Schema(context.Context, *SchemaRequest) (*SchemaResponse, error)

+ func (UnimplementedTrailerServer) Service(context.Context, *ServiceRequest) (*ServiceResponse, error)

+ func (UnimplementedTrailerServer) Start(context.Context, *Request) (*Response, error)

+ func (UnimplementedTrailerServer) Status(context.Context, *Request) (*StatusResponse, error)

+ func (UnimplementedTrailerServer) Stop(context.Context, *Request) (*Response, error)

+ type UnsafeTrailerServer interface

+ type ValueType int32

+ const ValueType_BOOL

+ const ValueType_NUMBER

+ const ValueType_STRING

+ func (ValueType) Descriptor() protoreflect.EnumDescriptor

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

+ func (ValueType) Type() protoreflect.EnumType

+ func (x ValueType) Enum() *ValueType

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

+ func (x ValueType) String() string