gpmv1

package
v1.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StatusInit      string = "init"      // 进程初始化, 还未启动过
	StatusRunning   string = "running"   // 进程正在运行中
	StatusStopped   string = "stopped"   // 进程停止
	StatusFailed    string = "failed"    // 进程执行失败
	StatusUpgrading string = "upgrading" // 进程升级中
)

Variables

View Source 
var (
	ErrInvalidLengthGpm        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGpm          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGpm = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type EditServiceSpec 

type EditServiceSpec struct {
	// 执行器路径
	Bin string `protobuf:"bytes,1,opt,name=bin,proto3" json:"bin,omitempty"`
	// 服务启动参数
	Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// 服务家目录
	Dir string `protobuf:"bytes,3,opt,name=dir,proto3" json:"dir,omitempty"`
	// 服务环境变量
	Env map[string]string `` /* 147-byte string literal not displayed */
	// 服务系统参数
	SysProcAttr *SysProcAttr `protobuf:"bytes,5,opt,name=sysProcAttr,proto3" json:"sysProcAttr,omitempty"`
	// 服务日志配置
	Log *ProcLog `protobuf:"bytes,6,opt,name=log,proto3" json:"log,omitempty"`
	// 是否自启动, 默认为 false
	AutoRestart int32 `protobuf:"varint,7,opt,name=autoRestart,proto3" json:"autoRestart,omitempty"`
}

func (*EditServiceSpec) DeepCopyInto 

func (in *EditServiceSpec) DeepCopyInto(out *EditServiceSpec)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*EditServiceSpec) Descriptor 

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

func (*EditServiceSpec) Marshal 

func (m *EditServiceSpec) Marshal() (dAtA []byte, err error)

func (*EditServiceSpec) MarshalTo 

func (m *EditServiceSpec) MarshalTo(dAtA []byte) (int, error)

func (*EditServiceSpec) MarshalToSizedBuffer 

func (m *EditServiceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EditServiceSpec) ProtoMessage 

func (*EditServiceSpec) ProtoMessage()

func (*EditServiceSpec) Reset 

func (m *EditServiceSpec) Reset()

func (*EditServiceSpec) String 

func (m *EditServiceSpec) String() string

func (*EditServiceSpec) Unmarshal 

func (m *EditServiceSpec) Unmarshal(dAtA []byte) error

func (*EditServiceSpec) Validate 

func (m *EditServiceSpec) Validate() error

func (*EditServiceSpec) ValidateE 

func (m *EditServiceSpec) ValidateE(prefix string) error

func (*EditServiceSpec) XSize 

func (m *EditServiceSpec) XSize() (n int)

func (*EditServiceSpec) XXX_DiscardUnknown 

func (m *EditServiceSpec) XXX_DiscardUnknown()

func (*EditServiceSpec) XXX_Marshal 

func (m *EditServiceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EditServiceSpec) XXX_Merge 

func (m *EditServiceSpec) XXX_Merge(src proto.Message)

func (*EditServiceSpec) XXX_Size 

func (m *EditServiceSpec) XXX_Size() int

func (*EditServiceSpec) XXX_Unmarshal 

func (m *EditServiceSpec) XXX_Unmarshal(b []byte) error

type ExecIn 

type ExecIn struct {
	// +gen:required
	Shell string            `protobuf:"bytes,1,opt,name=shell,proto3" json:"shell,omitempty"`
	Dir   string            `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	Env   map[string]string `` /* 147-byte string literal not displayed */
	User  string            `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Group string            `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
}

func (*ExecIn) DeepCopyInto 

func (in *ExecIn) DeepCopyInto(out *ExecIn)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*ExecIn) Descriptor 

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

func (*ExecIn) Marshal 

func (m *ExecIn) Marshal() (dAtA []byte, err error)

func (*ExecIn) MarshalTo 

func (m *ExecIn) MarshalTo(dAtA []byte) (int, error)

func (*ExecIn) MarshalToSizedBuffer 

func (m *ExecIn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecIn) ProtoMessage 

func (*ExecIn) ProtoMessage()

func (*ExecIn) Reset 

func (m *ExecIn) Reset()

func (*ExecIn) String 

func (m *ExecIn) String() string

func (*ExecIn) Unmarshal 

func (m *ExecIn) Unmarshal(dAtA []byte) error

func (*ExecIn) Validate 

func (m *ExecIn) Validate() error

func (*ExecIn) ValidateE 

func (m *ExecIn) ValidateE(prefix string) error

func (*ExecIn) XSize 

func (m *ExecIn) XSize() (n int)

func (*ExecIn) XXX_DiscardUnknown 

func (m *ExecIn) XXX_DiscardUnknown()

func (*ExecIn) XXX_Marshal 

func (m *ExecIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecIn) XXX_Merge 

func (m *ExecIn) XXX_Merge(src proto.Message)

func (*ExecIn) XXX_Size 

func (m *ExecIn) XXX_Size() int

func (*ExecIn) XXX_Unmarshal 

func (m *ExecIn) XXX_Unmarshal(b []byte) error

type ExecResult 

type ExecResult struct {
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*ExecResult) DeepCopyInto 

func (in *ExecResult) DeepCopyInto(out *ExecResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*ExecResult) Descriptor 

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

func (*ExecResult) Marshal 

func (m *ExecResult) Marshal() (dAtA []byte, err error)

func (*ExecResult) MarshalTo 

func (m *ExecResult) MarshalTo(dAtA []byte) (int, error)

func (*ExecResult) MarshalToSizedBuffer 

func (m *ExecResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecResult) ProtoMessage 

func (*ExecResult) ProtoMessage()

func (*ExecResult) Reset 

func (m *ExecResult) Reset()

func (*ExecResult) String 

func (m *ExecResult) String() string

func (*ExecResult) Unmarshal 

func (m *ExecResult) Unmarshal(dAtA []byte) error

func (*ExecResult) Validate 

func (m *ExecResult) Validate() error

func (*ExecResult) ValidateE 

func (m *ExecResult) ValidateE(prefix string) error

func (*ExecResult) XSize 

func (m *ExecResult) XSize() (n int)

func (*ExecResult) XXX_DiscardUnknown 

func (m *ExecResult) XXX_DiscardUnknown()

func (*ExecResult) XXX_Marshal 

func (m *ExecResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecResult) XXX_Merge 

func (m *ExecResult) XXX_Merge(src proto.Message)

func (*ExecResult) XXX_Size 

func (m *ExecResult) XXX_Size() int

func (*ExecResult) XXX_Unmarshal 

func (m *ExecResult) XXX_Unmarshal(b []byte) error

type FileInfo 

type FileInfo struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size    int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Mode    string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	ModTime int64  `protobuf:"varint,4,opt,name=modTime,proto3" json:"modTime,omitempty"`
	IsDir   bool   `protobuf:"varint,5,opt,name=IsDir,proto3" json:"IsDir,omitempty"`
}

func (*FileInfo) DeepCopyInto 

func (in *FileInfo) DeepCopyInto(out *FileInfo)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*FileInfo) Descriptor 

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

func (*FileInfo) Marshal 

func (m *FileInfo) Marshal() (dAtA []byte, err error)

func (*FileInfo) MarshalTo 

func (m *FileInfo) MarshalTo(dAtA []byte) (int, error)

func (*FileInfo) MarshalToSizedBuffer 

func (m *FileInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) String 

func (m *FileInfo) String() string

func (*FileInfo) Unmarshal 

func (m *FileInfo) Unmarshal(dAtA []byte) error

func (*FileInfo) Validate 

func (m *FileInfo) Validate() error

func (*FileInfo) ValidateE 

func (m *FileInfo) ValidateE(prefix string) error

func (*FileInfo) XSize 

func (m *FileInfo) XSize() (n int)

func (*FileInfo) XXX_DiscardUnknown 

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal 

func (m *FileInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileInfo) XXX_Merge 

func (m *FileInfo) XXX_Merge(src proto.Message)

func (*FileInfo) XXX_Size 

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal 

func (m *FileInfo) XXX_Unmarshal(b []byte) error

type GpmInfo 

type GpmInfo struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Goos    string `protobuf:"bytes,4,opt,name=goos,proto3" json:"goos,omitempty"`
	Arch    string `protobuf:"bytes,5,opt,name=arch,proto3" json:"arch,omitempty"`
	Gov     string `protobuf:"bytes,6,opt,name=gov,proto3" json:"gov,omitempty"`
	Pid     int32  `protobuf:"varint,7,opt,name=pid,proto3" json:"pid,omitempty"`
	Stat    *Stat  `protobuf:"bytes,8,opt,name=stat,proto3" json:"stat,omitempty"`
	UpTime  int64  `protobuf:"varint,9,opt,name=upTime,proto3" json:"upTime,omitempty"`
}

func (*GpmInfo) DeepCopyInto 

func (in *GpmInfo) DeepCopyInto(out *GpmInfo)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*GpmInfo) Descriptor 

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

func (*GpmInfo) Marshal 

func (m *GpmInfo) Marshal() (dAtA []byte, err error)

func (*GpmInfo) MarshalTo 

func (m *GpmInfo) MarshalTo(dAtA []byte) (int, error)

func (*GpmInfo) MarshalToSizedBuffer 

func (m *GpmInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GpmInfo) ProtoMessage 

func (*GpmInfo) ProtoMessage()

func (*GpmInfo) Reset 

func (m *GpmInfo) Reset()

func (*GpmInfo) String 

func (m *GpmInfo) String() string

func (*GpmInfo) Unmarshal 

func (m *GpmInfo) Unmarshal(dAtA []byte) error

func (*GpmInfo) Validate 

func (m *GpmInfo) Validate() error

func (*GpmInfo) ValidateE 

func (m *GpmInfo) ValidateE(prefix string) error

func (*GpmInfo) XSize 

func (m *GpmInfo) XSize() (n int)

func (*GpmInfo) XXX_DiscardUnknown 

func (m *GpmInfo) XXX_DiscardUnknown()

func (*GpmInfo) XXX_Marshal 

func (m *GpmInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GpmInfo) XXX_Merge 

func (m *GpmInfo) XXX_Merge(src proto.Message)

func (*GpmInfo) XXX_Size 

func (m *GpmInfo) XXX_Size() int

func (*GpmInfo) XXX_Unmarshal 

func (m *GpmInfo) XXX_Unmarshal(b []byte) error

type InstallServiceIn 

type InstallServiceIn struct {
	// +gen:required
	Spec *ServiceSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// +gen:required
	Pack *Package `protobuf:"bytes,2,opt,name=pack,proto3" json:"pack,omitempty"`
}

func (*InstallServiceIn) DeepCopyInto 

func (in *InstallServiceIn) DeepCopyInto(out *InstallServiceIn)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*InstallServiceIn) Descriptor 

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

func (*InstallServiceIn) Marshal 

func (m *InstallServiceIn) Marshal() (dAtA []byte, err error)

func (*InstallServiceIn) MarshalTo 

func (m *InstallServiceIn) MarshalTo(dAtA []byte) (int, error)

func (*InstallServiceIn) MarshalToSizedBuffer 

func (m *InstallServiceIn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InstallServiceIn) ProtoMessage 

func (*InstallServiceIn) ProtoMessage()

func (*InstallServiceIn) Reset 

func (m *InstallServiceIn) Reset()

func (*InstallServiceIn) String 

func (m *InstallServiceIn) String() string

func (*InstallServiceIn) Unmarshal 

func (m *InstallServiceIn) Unmarshal(dAtA []byte) error

func (*InstallServiceIn) Validate 

func (m *InstallServiceIn) Validate() error

func (*InstallServiceIn) ValidateE 

func (m *InstallServiceIn) ValidateE(prefix string) error

func (*InstallServiceIn) XSize 

func (m *InstallServiceIn) XSize() (n int)

func (*InstallServiceIn) XXX_DiscardUnknown 

func (m *InstallServiceIn) XXX_DiscardUnknown()

func (*InstallServiceIn) XXX_Marshal 

func (m *InstallServiceIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstallServiceIn) XXX_Merge 

func (m *InstallServiceIn) XXX_Merge(src proto.Message)

func (*InstallServiceIn) XXX_Size 

func (m *InstallServiceIn) XXX_Size() int

func (*InstallServiceIn) XXX_Unmarshal 

func (m *InstallServiceIn) XXX_Unmarshal(b []byte) error

type InstallServiceResult 

type InstallServiceResult struct {
	IsOk  bool   `protobuf:"varint,1,opt,name=isOk,proto3" json:"isOk,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*InstallServiceResult) DeepCopyInto 

func (in *InstallServiceResult) DeepCopyInto(out *InstallServiceResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*InstallServiceResult) Descriptor 

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

func (*InstallServiceResult) Marshal 

func (m *InstallServiceResult) Marshal() (dAtA []byte, err error)

func (*InstallServiceResult) MarshalTo 

func (m *InstallServiceResult) MarshalTo(dAtA []byte) (int, error)

func (*InstallServiceResult) MarshalToSizedBuffer 

func (m *InstallServiceResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InstallServiceResult) ProtoMessage 

func (*InstallServiceResult) ProtoMessage()

func (*InstallServiceResult) Reset 

func (m *InstallServiceResult) Reset()

func (*InstallServiceResult) String 

func (m *InstallServiceResult) String() string

func (*InstallServiceResult) Unmarshal 

func (m *InstallServiceResult) Unmarshal(dAtA []byte) error

func (*InstallServiceResult) Validate 

func (m *InstallServiceResult) Validate() error

func (*InstallServiceResult) ValidateE 

func (m *InstallServiceResult) ValidateE(prefix string) error

func (*InstallServiceResult) XSize 

func (m *InstallServiceResult) XSize() (n int)

func (*InstallServiceResult) XXX_DiscardUnknown 

func (m *InstallServiceResult) XXX_DiscardUnknown()

func (*InstallServiceResult) XXX_Marshal 

func (m *InstallServiceResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstallServiceResult) XXX_Merge 

func (m *InstallServiceResult) XXX_Merge(src proto.Message)

func (*InstallServiceResult) XXX_Size 

func (m *InstallServiceResult) XXX_Size() int

func (*InstallServiceResult) XXX_Unmarshal 

func (m *InstallServiceResult) XXX_Unmarshal(b []byte) error

type Package 

type Package struct {
	// +gen:required
	Package string `protobuf:"bytes,1,opt,name=package,proto3" json:"package,omitempty"`
	// +gen:required
	Total  int64  `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Chunk  []byte `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Length int64  `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	IsOk   bool   `protobuf:"varint,5,opt,name=isOk,proto3" json:"isOk,omitempty"`
}

func (*Package) DeepCopyInto 

func (in *Package) DeepCopyInto(out *Package)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Package) Descriptor 

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

func (*Package) Marshal 

func (m *Package) Marshal() (dAtA []byte, err error)

func (*Package) MarshalTo 

func (m *Package) MarshalTo(dAtA []byte) (int, error)

func (*Package) MarshalToSizedBuffer 

func (m *Package) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Package) ProtoMessage 

func (*Package) ProtoMessage()

func (*Package) Reset 

func (m *Package) Reset()

func (*Package) String 

func (m *Package) String() string

func (*Package) Unmarshal 

func (m *Package) Unmarshal(dAtA []byte) error

func (*Package) Validate 

func (m *Package) Validate() error

func (*Package) ValidateE 

func (m *Package) ValidateE(prefix string) error

func (*Package) XSize 

func (m *Package) XSize() (n int)

func (*Package) XXX_DiscardUnknown 

func (m *Package) XXX_DiscardUnknown()

func (*Package) XXX_Marshal 

func (m *Package) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Package) XXX_Merge 

func (m *Package) XXX_Merge(src proto.Message)

func (*Package) XXX_Size 

func (m *Package) XXX_Size() int

func (*Package) XXX_Unmarshal 

func (m *Package) XXX_Unmarshal(b []byte) error

type ProcLog 

type ProcLog struct {
	// 日志过期时间(天)
	// +gen:default=30
	Expire int32 `protobuf:"varint,1,opt,name=expire,proto3" json:"expire,omitempty"`
	// 日志最大容量，超过此容量则拆分日志
	MaxSize int64 `protobuf:"varint,2,opt,name=maxSize,proto3" json:"maxSize,omitempty"`
}

func (*ProcLog) DeepCopyInto 

func (in *ProcLog) DeepCopyInto(out *ProcLog)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*ProcLog) Descriptor 

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

func (*ProcLog) Marshal 

func (m *ProcLog) Marshal() (dAtA []byte, err error)

func (*ProcLog) MarshalTo 

func (m *ProcLog) MarshalTo(dAtA []byte) (int, error)

func (*ProcLog) MarshalToSizedBuffer 

func (m *ProcLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcLog) ProtoMessage 

func (*ProcLog) ProtoMessage()

func (*ProcLog) Reset 

func (m *ProcLog) Reset()

func (*ProcLog) String 

func (m *ProcLog) String() string

func (*ProcLog) Unmarshal 

func (m *ProcLog) Unmarshal(dAtA []byte) error

func (*ProcLog) Validate 

func (m *ProcLog) Validate() error

func (*ProcLog) ValidateE 

func (m *ProcLog) ValidateE(prefix string) error

func (*ProcLog) XSize 

func (m *ProcLog) XSize() (n int)

func (*ProcLog) XXX_DiscardUnknown 

func (m *ProcLog) XXX_DiscardUnknown()

func (*ProcLog) XXX_Marshal 

func (m *ProcLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcLog) XXX_Merge 

func (m *ProcLog) XXX_Merge(src proto.Message)

func (*ProcLog) XXX_Size 

func (m *ProcLog) XXX_Size() int

func (*ProcLog) XXX_Unmarshal 

func (m *ProcLog) XXX_Unmarshal(b []byte) error

type PullResult 

type PullResult struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Total    int64  `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Chunk    []byte `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Length   int64  `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	Error    string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Finished bool   `protobuf:"varint,6,opt,name=finished,proto3" json:"finished,omitempty"`
}

func (*PullResult) DeepCopyInto 

func (in *PullResult) DeepCopyInto(out *PullResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*PullResult) Descriptor 

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

func (*PullResult) Marshal 

func (m *PullResult) Marshal() (dAtA []byte, err error)

func (*PullResult) MarshalTo 

func (m *PullResult) MarshalTo(dAtA []byte) (int, error)

func (*PullResult) MarshalToSizedBuffer 

func (m *PullResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PullResult) ProtoMessage 

func (*PullResult) ProtoMessage()

func (*PullResult) Reset 

func (m *PullResult) Reset()

func (*PullResult) String 

func (m *PullResult) String() string

func (*PullResult) Unmarshal 

func (m *PullResult) Unmarshal(dAtA []byte) error

func (*PullResult) Validate 

func (m *PullResult) Validate() error

func (*PullResult) ValidateE 

func (m *PullResult) ValidateE(prefix string) error

func (*PullResult) XSize 

func (m *PullResult) XSize() (n int)

func (*PullResult) XXX_DiscardUnknown 

func (m *PullResult) XXX_DiscardUnknown()

func (*PullResult) XXX_Marshal 

func (m *PullResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullResult) XXX_Merge 

func (m *PullResult) XXX_Merge(src proto.Message)

func (*PullResult) XXX_Size 

func (m *PullResult) XXX_Size() int

func (*PullResult) XXX_Unmarshal 

func (m *PullResult) XXX_Unmarshal(b []byte) error

type PushIn 

type PushIn struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Dst    string `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	Total  int64  `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	Chunk  []byte `protobuf:"bytes,4,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Length int64  `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"`
	IsOk   bool   `protobuf:"varint,6,opt,name=isOk,proto3" json:"isOk,omitempty"`
}

func (*PushIn) DeepCopyInto 

func (in *PushIn) DeepCopyInto(out *PushIn)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*PushIn) Descriptor 

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

func (*PushIn) Marshal 

func (m *PushIn) Marshal() (dAtA []byte, err error)

func (*PushIn) MarshalTo 

func (m *PushIn) MarshalTo(dAtA []byte) (int, error)

func (*PushIn) MarshalToSizedBuffer 

func (m *PushIn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushIn) ProtoMessage 

func (*PushIn) ProtoMessage()

func (*PushIn) Reset 

func (m *PushIn) Reset()

func (*PushIn) String 

func (m *PushIn) String() string

func (*PushIn) Unmarshal 

func (m *PushIn) Unmarshal(dAtA []byte) error

func (*PushIn) Validate 

func (m *PushIn) Validate() error

func (*PushIn) ValidateE 

func (m *PushIn) ValidateE(prefix string) error

func (*PushIn) XSize 

func (m *PushIn) XSize() (n int)

func (*PushIn) XXX_DiscardUnknown 

func (m *PushIn) XXX_DiscardUnknown()

func (*PushIn) XXX_Marshal 

func (m *PushIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushIn) XXX_Merge 

func (m *PushIn) XXX_Merge(src proto.Message)

func (*PushIn) XXX_Size 

func (m *PushIn) XXX_Size() int

func (*PushIn) XXX_Unmarshal 

func (m *PushIn) XXX_Unmarshal(b []byte) error

type Service 

type Service struct {
	// 服务名称
	// +gen:required
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// 执行器路径
	// +gen:required
	Bin string `protobuf:"bytes,2,opt,name=bin,proto3" json:"bin,omitempty"`
	// 服务启动参数
	Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// 服务进程 id
	Pid int64 `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
	// 服务目录
	Dir string `protobuf:"bytes,5,opt,name=dir,proto3" json:"dir,omitempty"`
	// 服务环境变量
	Env map[string]string `` /* 147-byte string literal not displayed */
	// 服务系统参数
	SysProcAttr *SysProcAttr `protobuf:"bytes,7,opt,name=sysProcAttr,proto3" json:"sysProcAttr,omitempty"`
	// 服务进程日志配置
	Log *ProcLog `protobuf:"bytes,8,opt,name=log,proto3" json:"log,omitempty"`
	// 服务版本
	Version string `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	// 是否自启动, 默认为 false
	AutoRestart int32 `protobuf:"varint,10,opt,name=autoRestart,proto3" json:"autoRestart,omitempty"`
	// 是否为 install 服务, gpmd 设置
	InstallFlag int32 `protobuf:"varint,11,opt,name=installFlag,proto3" json:"installFlag,omitempty"`
	// 创建时间
	CreationTimestamp int64 `protobuf:"varint,21,opt,name=creationTimestamp,proto3" json:"creationTimestamp,omitempty"`
	// 修改时间
	UpdateTimestamp int64 `protobuf:"varint,22,opt,name=updateTimestamp,proto3" json:"updateTimestamp,omitempty"`
	// 启动时间
	StartTimestamp int64 `protobuf:"varint,23,opt,name=startTimestamp,proto3" json:"startTimestamp,omitempty"`
	// 服务状态
	// +gen:enum=[init,running,stopped,failed,upgrading]
	Status string `protobuf:"bytes,24,opt,name=status,proto3" json:"status,omitempty"`
	// 服务状态为 failed 的错误信息
	Msg string `protobuf:"bytes,25,opt,name=msg,proto3" json:"msg,omitempty"`
	// 服务资源占用情况
	Stat *Stat `protobuf:"bytes,26,opt,name=stat,proto3" json:"stat,omitempty"`
}

func (*Service) DeepCopyInto 

func (in *Service) DeepCopyInto(out *Service)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Service) Descriptor 

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

func (*Service) Marshal 

func (m *Service) Marshal() (dAtA []byte, err error)

func (*Service) MarshalTo 

func (m *Service) MarshalTo(dAtA []byte) (int, error)

func (*Service) MarshalToSizedBuffer 

func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) Unmarshal 

func (m *Service) Unmarshal(dAtA []byte) error

func (*Service) Validate 

func (m *Service) Validate() error

func (*Service) ValidateE 

func (m *Service) ValidateE(prefix string) error

func (*Service) XSize 

func (m *Service) XSize() (n int)

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type ServiceLog 

type ServiceLog struct {
	Text      string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
	Error     string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*ServiceLog) DeepCopyInto 

func (in *ServiceLog) DeepCopyInto(out *ServiceLog)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*ServiceLog) Descriptor 

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

func (*ServiceLog) Marshal 

func (m *ServiceLog) Marshal() (dAtA []byte, err error)

func (*ServiceLog) MarshalTo 

func (m *ServiceLog) MarshalTo(dAtA []byte) (int, error)

func (*ServiceLog) MarshalToSizedBuffer 

func (m *ServiceLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceLog) ProtoMessage 

func (*ServiceLog) ProtoMessage()

func (*ServiceLog) Reset 

func (m *ServiceLog) Reset()

func (*ServiceLog) String 

func (m *ServiceLog) String() string

func (*ServiceLog) Unmarshal 

func (m *ServiceLog) Unmarshal(dAtA []byte) error

func (*ServiceLog) Validate 

func (m *ServiceLog) Validate() error

func (*ServiceLog) ValidateE 

func (m *ServiceLog) ValidateE(prefix string) error

func (*ServiceLog) XSize 

func (m *ServiceLog) XSize() (n int)

func (*ServiceLog) XXX_DiscardUnknown 

func (m *ServiceLog) XXX_DiscardUnknown()

func (*ServiceLog) XXX_Marshal 

func (m *ServiceLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceLog) XXX_Merge 

func (m *ServiceLog) XXX_Merge(src proto.Message)

func (*ServiceLog) XXX_Size 

func (m *ServiceLog) XXX_Size() int

func (*ServiceLog) XXX_Unmarshal 

func (m *ServiceLog) XXX_Unmarshal(b []byte) error

type ServiceSpec 

type ServiceSpec struct {
	// 服务名称
	// +gen:required
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// 执行器路径
	// +gen:required
	Bin string `protobuf:"bytes,2,opt,name=bin,proto3" json:"bin,omitempty"`
	// 服务启动参数
	Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// 服务家目录
	Dir string `protobuf:"bytes,4,opt,name=dir,proto3" json:"dir,omitempty"`
	// 服务环境变量
	Env map[string]string `` /* 147-byte string literal not displayed */
	// 服务系统参数
	SysProcAttr *SysProcAttr `protobuf:"bytes,6,opt,name=sysProcAttr,proto3" json:"sysProcAttr,omitempty"`
	// 服务日志配置
	Log *ProcLog `protobuf:"bytes,7,opt,name=log,proto3" json:"log,omitempty"`
	// 服务版本
	// +gen:required
	Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	// 是否自启动, 默认为 false
	AutoRestart int32 `protobuf:"varint,9,opt,name=autoRestart,proto3" json:"autoRestart,omitempty"`
	// tar 头部路径
	// headerTrimPrefix 不为空时, 解压 tar 包时，内部文件的路径会发生变化
	// 如 dir=/opt/test/a, hdr=b/bin/test, headerTrimPrefix=b, test 文件的路径为 /opt/test/a/bin/test
	HeaderTrimPrefix string `protobuf:"bytes,10,opt,name=headerTrimPrefix,proto3" json:"headerTrimPrefix,omitempty"`
	// 是否为 install 服务, gpmd 设置
	InstallFlag int32 `protobuf:"varint,11,opt,name=installFlag,proto3" json:"installFlag,omitempty"`
}

func (*ServiceSpec) DeepCopyInto 

func (in *ServiceSpec) DeepCopyInto(out *ServiceSpec)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*ServiceSpec) Descriptor 

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

func (*ServiceSpec) Marshal 

func (m *ServiceSpec) Marshal() (dAtA []byte, err error)

func (*ServiceSpec) MarshalTo 

func (m *ServiceSpec) MarshalTo(dAtA []byte) (int, error)

func (*ServiceSpec) MarshalToSizedBuffer 

func (m *ServiceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceSpec) ProtoMessage 

func (*ServiceSpec) ProtoMessage()

func (*ServiceSpec) Reset 

func (m *ServiceSpec) Reset()

func (*ServiceSpec) String 

func (m *ServiceSpec) String() string

func (*ServiceSpec) Unmarshal 

func (m *ServiceSpec) Unmarshal(dAtA []byte) error

func (*ServiceSpec) Validate 

func (m *ServiceSpec) Validate() error

func (*ServiceSpec) ValidateE 

func (m *ServiceSpec) ValidateE(prefix string) error

func (*ServiceSpec) XSize 

func (m *ServiceSpec) XSize() (n int)

func (*ServiceSpec) XXX_DiscardUnknown 

func (m *ServiceSpec) XXX_DiscardUnknown()

func (*ServiceSpec) XXX_Marshal 

func (m *ServiceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceSpec) XXX_Merge 

func (m *ServiceSpec) XXX_Merge(src proto.Message)

func (*ServiceSpec) XXX_Size 

func (m *ServiceSpec) XXX_Size() int

func (*ServiceSpec) XXX_Unmarshal 

func (m *ServiceSpec) XXX_Unmarshal(b []byte) error

type ServiceVersion 

type ServiceVersion struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*ServiceVersion) DeepCopyInto 

func (in *ServiceVersion) DeepCopyInto(out *ServiceVersion)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*ServiceVersion) Descriptor 

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

func (*ServiceVersion) Marshal 

func (m *ServiceVersion) Marshal() (dAtA []byte, err error)

func (*ServiceVersion) MarshalTo 

func (m *ServiceVersion) MarshalTo(dAtA []byte) (int, error)

func (*ServiceVersion) MarshalToSizedBuffer 

func (m *ServiceVersion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceVersion) ProtoMessage 

func (*ServiceVersion) ProtoMessage()

func (*ServiceVersion) Reset 

func (m *ServiceVersion) Reset()

func (*ServiceVersion) String 

func (m *ServiceVersion) String() string

func (*ServiceVersion) Unmarshal 

func (m *ServiceVersion) Unmarshal(dAtA []byte) error

func (*ServiceVersion) Validate 

func (m *ServiceVersion) Validate() error

func (*ServiceVersion) ValidateE 

func (m *ServiceVersion) ValidateE(prefix string) error

func (*ServiceVersion) XSize 

func (m *ServiceVersion) XSize() (n int)

func (*ServiceVersion) XXX_DiscardUnknown 

func (m *ServiceVersion) XXX_DiscardUnknown()

func (*ServiceVersion) XXX_Marshal 

func (m *ServiceVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceVersion) XXX_Merge 

func (m *ServiceVersion) XXX_Merge(src proto.Message)

func (*ServiceVersion) XXX_Size 

func (m *ServiceVersion) XXX_Size() int

func (*ServiceVersion) XXX_Unmarshal 

func (m *ServiceVersion) XXX_Unmarshal(b []byte) error

type Stat 

type Stat struct {
	// cpu 占用百分比
	CpuPercent float64 `protobuf:"fixed64,1,opt,name=cpuPercent,proto3" json:"cpuPercent,omitempty"`
	// 内存占用, rss
	Memory uint64 `protobuf:"varint,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// 内存占用百分比
	MemPercent float32 `protobuf:"fixed32,3,opt,name=memPercent,proto3" json:"memPercent,omitempty"`
}

func (*Stat) DeepCopyInto 

func (in *Stat) DeepCopyInto(out *Stat)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Stat) Descriptor 

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

func (*Stat) Marshal 

func (m *Stat) Marshal() (dAtA []byte, err error)

func (*Stat) MarshalTo 

func (m *Stat) MarshalTo(dAtA []byte) (int, error)

func (*Stat) MarshalToSizedBuffer 

func (m *Stat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stat) ProtoMessage 

func (*Stat) ProtoMessage()

func (*Stat) Reset 

func (m *Stat) Reset()

func (*Stat) String 

func (m *Stat) String() string

func (*Stat) Unmarshal 

func (m *Stat) Unmarshal(dAtA []byte) error

func (*Stat) Validate 

func (m *Stat) Validate() error

func (*Stat) ValidateE 

func (m *Stat) ValidateE(prefix string) error

func (*Stat) XSize 

func (m *Stat) XSize() (n int)

func (*Stat) XXX_DiscardUnknown 

func (m *Stat) XXX_DiscardUnknown()

func (*Stat) XXX_Marshal 

func (m *Stat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stat) XXX_Merge 

func (m *Stat) XXX_Merge(src proto.Message)

func (*Stat) XXX_Size 

func (m *Stat) XXX_Size() int

func (*Stat) XXX_Unmarshal 

func (m *Stat) XXX_Unmarshal(b []byte) error

type SysProcAttr 

type SysProcAttr struct {
	// 执行命令时所在的根目录
	Chroot string `protobuf:"bytes,1,opt,name=chroot,proto3" json:"chroot,omitempty"`
	// 执行服务时所用的 uid (windows 无效)
	Uid int32 `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// uid 对应的用户名称
	User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// 执行服务时所有的 gid (windows 无效)
	Gid int32 `protobuf:"varint,4,opt,name=gid,proto3" json:"gid,omitempty"`
	// gid 对应的用户组
	Group string `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
}

func (*SysProcAttr) DeepCopyInto 

func (in *SysProcAttr) DeepCopyInto(out *SysProcAttr)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*SysProcAttr) Descriptor 

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

func (*SysProcAttr) Marshal 

func (m *SysProcAttr) Marshal() (dAtA []byte, err error)

func (*SysProcAttr) MarshalTo 

func (m *SysProcAttr) MarshalTo(dAtA []byte) (int, error)

func (*SysProcAttr) MarshalToSizedBuffer 

func (m *SysProcAttr) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SysProcAttr) ProtoMessage 

func (*SysProcAttr) ProtoMessage()

func (*SysProcAttr) Reset 

func (m *SysProcAttr) Reset()

func (*SysProcAttr) String 

func (m *SysProcAttr) String() string

func (*SysProcAttr) Unmarshal 

func (m *SysProcAttr) Unmarshal(dAtA []byte) error

func (*SysProcAttr) Validate 

func (m *SysProcAttr) Validate() error

func (*SysProcAttr) ValidateE 

func (m *SysProcAttr) ValidateE(prefix string) error

func (*SysProcAttr) XSize 

func (m *SysProcAttr) XSize() (n int)

func (*SysProcAttr) XXX_DiscardUnknown 

func (m *SysProcAttr) XXX_DiscardUnknown()

func (*SysProcAttr) XXX_Marshal 

func (m *SysProcAttr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SysProcAttr) XXX_Merge 

func (m *SysProcAttr) XXX_Merge(src proto.Message)

func (*SysProcAttr) XXX_Size 

func (m *SysProcAttr) XXX_Size() int

func (*SysProcAttr) XXX_Unmarshal 

func (m *SysProcAttr) XXX_Unmarshal(b []byte) error

type TerminalIn 

type TerminalIn struct {
	// +gen:required
	Command string            `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Env     map[string]string `` /* 147-byte string literal not displayed */
	User    string            `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Group   string            `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
}

func (*TerminalIn) DeepCopyInto 

func (in *TerminalIn) DeepCopyInto(out *TerminalIn)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*TerminalIn) Descriptor 

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

func (*TerminalIn) Marshal 

func (m *TerminalIn) Marshal() (dAtA []byte, err error)

func (*TerminalIn) MarshalTo 

func (m *TerminalIn) MarshalTo(dAtA []byte) (int, error)

func (*TerminalIn) MarshalToSizedBuffer 

func (m *TerminalIn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TerminalIn) ProtoMessage 

func (*TerminalIn) ProtoMessage()

func (*TerminalIn) Reset 

func (m *TerminalIn) Reset()

func (*TerminalIn) String 

func (m *TerminalIn) String() string

func (*TerminalIn) Unmarshal 

func (m *TerminalIn) Unmarshal(dAtA []byte) error

func (*TerminalIn) Validate 

func (m *TerminalIn) Validate() error

func (*TerminalIn) ValidateE 

func (m *TerminalIn) ValidateE(prefix string) error

func (*TerminalIn) XSize 

func (m *TerminalIn) XSize() (n int)

func (*TerminalIn) XXX_DiscardUnknown 

func (m *TerminalIn) XXX_DiscardUnknown()

func (*TerminalIn) XXX_Marshal 

func (m *TerminalIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminalIn) XXX_Merge 

func (m *TerminalIn) XXX_Merge(src proto.Message)

func (*TerminalIn) XXX_Size 

func (m *TerminalIn) XXX_Size() int

func (*TerminalIn) XXX_Unmarshal 

func (m *TerminalIn) XXX_Unmarshal(b []byte) error

type TerminalResult 

type TerminalResult struct {
	Stdout []byte `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr []byte `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Error  []byte `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	IsOk   bool   `protobuf:"varint,4,opt,name=isOk,proto3" json:"isOk,omitempty"`
}

func (*TerminalResult) DeepCopyInto 

func (in *TerminalResult) DeepCopyInto(out *TerminalResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*TerminalResult) Descriptor 

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

func (*TerminalResult) Marshal 

func (m *TerminalResult) Marshal() (dAtA []byte, err error)

func (*TerminalResult) MarshalTo 

func (m *TerminalResult) MarshalTo(dAtA []byte) (int, error)

func (*TerminalResult) MarshalToSizedBuffer 

func (m *TerminalResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TerminalResult) ProtoMessage 

func (*TerminalResult) ProtoMessage()

func (*TerminalResult) Reset 

func (m *TerminalResult) Reset()

func (*TerminalResult) String 

func (m *TerminalResult) String() string

func (*TerminalResult) Unmarshal 

func (m *TerminalResult) Unmarshal(dAtA []byte) error

func (*TerminalResult) Validate 

func (m *TerminalResult) Validate() error

func (*TerminalResult) ValidateE 

func (m *TerminalResult) ValidateE(prefix string) error

func (*TerminalResult) XSize 

func (m *TerminalResult) XSize() (n int)

func (*TerminalResult) XXX_DiscardUnknown 

func (m *TerminalResult) XXX_DiscardUnknown()

func (*TerminalResult) XXX_Marshal 

func (m *TerminalResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminalResult) XXX_Merge 

func (m *TerminalResult) XXX_Merge(src proto.Message)

func (*TerminalResult) XXX_Size 

func (m *TerminalResult) XXX_Size() int

func (*TerminalResult) XXX_Unmarshal 

func (m *TerminalResult) XXX_Unmarshal(b []byte) error

type UpdateIn 

type UpdateIn struct {
	// +gen:required
	Version      string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Total        int64  `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Chunk        []byte `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Length       int64  `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	IsOk         bool   `protobuf:"varint,5,opt,name=isOk,proto3" json:"isOk,omitempty"`
	DeploySignal bool   `protobuf:"varint,6,opt,name=deploySignal,proto3" json:"deploySignal,omitempty"`
}

func (*UpdateIn) DeepCopyInto 

func (in *UpdateIn) DeepCopyInto(out *UpdateIn)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*UpdateIn) Descriptor 

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

func (*UpdateIn) Marshal 

func (m *UpdateIn) Marshal() (dAtA []byte, err error)

func (*UpdateIn) MarshalTo 

func (m *UpdateIn) MarshalTo(dAtA []byte) (int, error)

func (*UpdateIn) MarshalToSizedBuffer 

func (m *UpdateIn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateIn) ProtoMessage 

func (*UpdateIn) ProtoMessage()

func (*UpdateIn) Reset 

func (m *UpdateIn) Reset()

func (*UpdateIn) String 

func (m *UpdateIn) String() string

func (*UpdateIn) Unmarshal 

func (m *UpdateIn) Unmarshal(dAtA []byte) error

func (*UpdateIn) Validate 

func (m *UpdateIn) Validate() error

func (*UpdateIn) ValidateE 

func (m *UpdateIn) ValidateE(prefix string) error

func (*UpdateIn) XSize 

func (m *UpdateIn) XSize() (n int)

func (*UpdateIn) XXX_DiscardUnknown 

func (m *UpdateIn) XXX_DiscardUnknown()

func (*UpdateIn) XXX_Marshal 

func (m *UpdateIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateIn) XXX_Merge 

func (m *UpdateIn) XXX_Merge(src proto.Message)

func (*UpdateIn) XXX_Size 

func (m *UpdateIn) XXX_Size() int

func (*UpdateIn) XXX_Unmarshal 

func (m *UpdateIn) XXX_Unmarshal(b []byte) error

type UpdateResult 

type UpdateResult struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	IsOk  bool   `protobuf:"varint,2,opt,name=isOk,proto3" json:"isOk,omitempty"`
}

func (*UpdateResult) DeepCopyInto 

func (in *UpdateResult) DeepCopyInto(out *UpdateResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*UpdateResult) Descriptor 

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

func (*UpdateResult) Marshal 

func (m *UpdateResult) Marshal() (dAtA []byte, err error)

func (*UpdateResult) MarshalTo 

func (m *UpdateResult) MarshalTo(dAtA []byte) (int, error)

func (*UpdateResult) MarshalToSizedBuffer 

func (m *UpdateResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateResult) ProtoMessage 

func (*UpdateResult) ProtoMessage()

func (*UpdateResult) Reset 

func (m *UpdateResult) Reset()

func (*UpdateResult) String 

func (m *UpdateResult) String() string

func (*UpdateResult) Unmarshal 

func (m *UpdateResult) Unmarshal(dAtA []byte) error

func (*UpdateResult) Validate 

func (m *UpdateResult) Validate() error

func (*UpdateResult) ValidateE 

func (m *UpdateResult) ValidateE(prefix string) error

func (*UpdateResult) XSize 

func (m *UpdateResult) XSize() (n int)

func (*UpdateResult) XXX_DiscardUnknown 

func (m *UpdateResult) XXX_DiscardUnknown()

func (*UpdateResult) XXX_Marshal 

func (m *UpdateResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateResult) XXX_Merge 

func (m *UpdateResult) XXX_Merge(src proto.Message)

func (*UpdateResult) XXX_Size 

func (m *UpdateResult) XXX_Size() int

func (*UpdateResult) XXX_Unmarshal 

func (m *UpdateResult) XXX_Unmarshal(b []byte) error

type UpgradeServiceIn 

type UpgradeServiceIn struct {
	// +gen:required
	Spec *UpgradeSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// +gen:required
	Pack *Package `protobuf:"bytes,2,opt,name=pack,proto3" json:"pack,omitempty"`
}

func (*UpgradeServiceIn) DeepCopyInto 

func (in *UpgradeServiceIn) DeepCopyInto(out *UpgradeServiceIn)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*UpgradeServiceIn) Descriptor 

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

func (*UpgradeServiceIn) Marshal 

func (m *UpgradeServiceIn) Marshal() (dAtA []byte, err error)

func (*UpgradeServiceIn) MarshalTo 

func (m *UpgradeServiceIn) MarshalTo(dAtA []byte) (int, error)

func (*UpgradeServiceIn) MarshalToSizedBuffer 

func (m *UpgradeServiceIn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpgradeServiceIn) ProtoMessage 

func (*UpgradeServiceIn) ProtoMessage()

func (*UpgradeServiceIn) Reset 

func (m *UpgradeServiceIn) Reset()

func (*UpgradeServiceIn) String 

func (m *UpgradeServiceIn) String() string

func (*UpgradeServiceIn) Unmarshal 

func (m *UpgradeServiceIn) Unmarshal(dAtA []byte) error

func (*UpgradeServiceIn) Validate 

func (m *UpgradeServiceIn) Validate() error

func (*UpgradeServiceIn) ValidateE 

func (m *UpgradeServiceIn) ValidateE(prefix string) error

func (*UpgradeServiceIn) XSize 

func (m *UpgradeServiceIn) XSize() (n int)

func (*UpgradeServiceIn) XXX_DiscardUnknown 

func (m *UpgradeServiceIn) XXX_DiscardUnknown()

func (*UpgradeServiceIn) XXX_Marshal 

func (m *UpgradeServiceIn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpgradeServiceIn) XXX_Merge 

func (m *UpgradeServiceIn) XXX_Merge(src proto.Message)

func (*UpgradeServiceIn) XXX_Size 

func (m *UpgradeServiceIn) XXX_Size() int

func (*UpgradeServiceIn) XXX_Unmarshal 

func (m *UpgradeServiceIn) XXX_Unmarshal(b []byte) error

type UpgradeServiceResult 

type UpgradeServiceResult struct {
	IsOk  bool   `protobuf:"varint,1,opt,name=isOk,proto3" json:"isOk,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*UpgradeServiceResult) DeepCopyInto 

func (in *UpgradeServiceResult) DeepCopyInto(out *UpgradeServiceResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*UpgradeServiceResult) Descriptor 

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

func (*UpgradeServiceResult) Marshal 

func (m *UpgradeServiceResult) Marshal() (dAtA []byte, err error)

func (*UpgradeServiceResult) MarshalTo 

func (m *UpgradeServiceResult) MarshalTo(dAtA []byte) (int, error)

func (*UpgradeServiceResult) MarshalToSizedBuffer 

func (m *UpgradeServiceResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpgradeServiceResult) ProtoMessage 

func (*UpgradeServiceResult) ProtoMessage()

func (*UpgradeServiceResult) Reset 

func (m *UpgradeServiceResult) Reset()

func (*UpgradeServiceResult) String 

func (m *UpgradeServiceResult) String() string

func (*UpgradeServiceResult) Unmarshal 

func (m *UpgradeServiceResult) Unmarshal(dAtA []byte) error

func (*UpgradeServiceResult) Validate 

func (m *UpgradeServiceResult) Validate() error

func (*UpgradeServiceResult) ValidateE 

func (m *UpgradeServiceResult) ValidateE(prefix string) error

func (*UpgradeServiceResult) XSize 

func (m *UpgradeServiceResult) XSize() (n int)

func (*UpgradeServiceResult) XXX_DiscardUnknown 

func (m *UpgradeServiceResult) XXX_DiscardUnknown()

func (*UpgradeServiceResult) XXX_Marshal 

func (m *UpgradeServiceResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpgradeServiceResult) XXX_Merge 

func (m *UpgradeServiceResult) XXX_Merge(src proto.Message)

func (*UpgradeServiceResult) XXX_Size 

func (m *UpgradeServiceResult) XXX_Size() int

func (*UpgradeServiceResult) XXX_Unmarshal 

func (m *UpgradeServiceResult) XXX_Unmarshal(b []byte) error

type UpgradeSpec added in v1.7.6 

type UpgradeSpec struct {
	// 服务名称
	// +gen:required
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// +gen:required
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// tar 头部路径
	// headerTrimPrefix 不为空时, 解压 tar 包时，内部文件的路径会发生变化
	// 如 dir=/opt/test/a, hdr=b/bin/test, headerTrimPrefix=b, test 文件的路径为 /opt/test/a/bin/test
	HeaderTrimPrefix string `protobuf:"bytes,3,opt,name=headerTrimPrefix,proto3" json:"headerTrimPrefix,omitempty"`
}

func (*UpgradeSpec) DeepCopyInto added in v1.7.6 

func (in *UpgradeSpec) DeepCopyInto(out *UpgradeSpec)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*UpgradeSpec) Descriptor added in v1.7.6 

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

func (*UpgradeSpec) Marshal added in v1.7.6 

func (m *UpgradeSpec) Marshal() (dAtA []byte, err error)

func (*UpgradeSpec) MarshalTo added in v1.7.6 

func (m *UpgradeSpec) MarshalTo(dAtA []byte) (int, error)

func (*UpgradeSpec) MarshalToSizedBuffer added in v1.7.6 

func (m *UpgradeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpgradeSpec) ProtoMessage added in v1.7.6 

func (*UpgradeSpec) ProtoMessage()

func (*UpgradeSpec) Reset added in v1.7.6 

func (m *UpgradeSpec) Reset()

func (*UpgradeSpec) String added in v1.7.6 

func (m *UpgradeSpec) String() string

func (*UpgradeSpec) Unmarshal added in v1.7.6 

func (m *UpgradeSpec) Unmarshal(dAtA []byte) error

func (*UpgradeSpec) Validate added in v1.7.6 

func (m *UpgradeSpec) Validate() error

func (*UpgradeSpec) ValidateE added in v1.7.6 

func (m *UpgradeSpec) ValidateE(prefix string) error

func (*UpgradeSpec) XSize added in v1.7.6 

func (m *UpgradeSpec) XSize() (n int)

func (*UpgradeSpec) XXX_DiscardUnknown added in v1.7.6 

func (m *UpgradeSpec) XXX_DiscardUnknown()

func (*UpgradeSpec) XXX_Marshal added in v1.7.6 

func (m *UpgradeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpgradeSpec) XXX_Merge added in v1.7.6 

func (m *UpgradeSpec) XXX_Merge(src proto.Message)

func (*UpgradeSpec) XXX_Size added in v1.7.6 

func (m *UpgradeSpec) XXX_Size() int

func (*UpgradeSpec) XXX_Unmarshal added in v1.7.6 

func (m *UpgradeSpec) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.