task

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterService 

func RegisterService(s giraffe_micro.Server, srv Service)

Types

type Client 

type Client interface {
	CreateSyncTask(ctx context.Context, in *CreateSyncTaskRequest) (*CreateSyncTaskResponse, error)
}

Client is the client API for task service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClient 

func NewClient(c giraffe_micro.Client) Client

type CreateSyncTaskRequest 

type CreateSyncTaskRequest struct {
	//
	//脚本Id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	//
	//执行用户,默认为root
	ExecUser string `protobuf:"bytes,2,opt,name=execUser,proto3" json:"execUser" form:"execUser"`
	//
	//args参数
	Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args" form:"args"`
	//
	//键值对参数, 完整的参数将会拼接为:`args[0] args[1] key1+sep1+value1 key2+sep2+value2`
	Kwargs []*CreateSyncTaskRequest_Kwargs `protobuf:"bytes,4,rep,name=kwargs,proto3" json:"kwargs" form:"kwargs"`
	//
	//执行目标
	Targets []*CreateSyncTaskRequest_Targets `protobuf:"bytes,5,rep,name=targets,proto3" json:"targets" form:"targets"`
	//
	//设置的目标机器分批执行的每批数量
	BatchNum int32 `protobuf:"varint,6,opt,name=batchNum,proto3" json:"batchNum" form:"batchNum"`
	//
	//设置的目标机器分批执行的每批之间的间隔秒数
	BatchInterval int32 `protobuf:"varint,7,opt,name=batchInterval,proto3" json:"batchInterval" form:"batchInterval"`
	//
	//输出是否转成json
	JsonOutput           bool     `protobuf:"varint,8,opt,name=jsonOutput,proto3" json:"jsonOutput" form:"jsonOutput"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateSyncTask请求

func (*CreateSyncTaskRequest) Descriptor 

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

func (*CreateSyncTaskRequest) GetArgs 

func (m *CreateSyncTaskRequest) GetArgs() []string

func (*CreateSyncTaskRequest) GetBatchInterval 

func (m *CreateSyncTaskRequest) GetBatchInterval() int32

func (*CreateSyncTaskRequest) GetBatchNum 

func (m *CreateSyncTaskRequest) GetBatchNum() int32

func (*CreateSyncTaskRequest) GetExecUser 

func (m *CreateSyncTaskRequest) GetExecUser() string

func (*CreateSyncTaskRequest) GetId 

func (m *CreateSyncTaskRequest) GetId() string

func (*CreateSyncTaskRequest) GetJsonOutput 

func (m *CreateSyncTaskRequest) GetJsonOutput() bool

func (*CreateSyncTaskRequest) GetKwargs 

func (m *CreateSyncTaskRequest) GetKwargs() []*CreateSyncTaskRequest_Kwargs

func (*CreateSyncTaskRequest) GetTargets 

func (m *CreateSyncTaskRequest) GetTargets() []*CreateSyncTaskRequest_Targets

func (*CreateSyncTaskRequest) ProtoMessage 

func (*CreateSyncTaskRequest) ProtoMessage()

func (*CreateSyncTaskRequest) Reset 

func (m *CreateSyncTaskRequest) Reset()

func (*CreateSyncTaskRequest) String 

func (m *CreateSyncTaskRequest) String() string

func (*CreateSyncTaskRequest) Validate 

func (this *CreateSyncTaskRequest) Validate() error

func (*CreateSyncTaskRequest) XXX_DiscardUnknown 

func (m *CreateSyncTaskRequest) XXX_DiscardUnknown()

func (*CreateSyncTaskRequest) XXX_Marshal 

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

func (*CreateSyncTaskRequest) XXX_Merge 

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

func (*CreateSyncTaskRequest) XXX_Size 

func (m *CreateSyncTaskRequest) XXX_Size() int

func (*CreateSyncTaskRequest) XXX_Unmarshal 

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

type CreateSyncTaskRequest_Kwargs 

type CreateSyncTaskRequest_Kwargs struct {
	//
	//参数key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key" form:"key"`
	//
	//连接符,默认为=
	Sep string `protobuf:"bytes,2,opt,name=sep,proto3" json:"sep" form:"sep"`
	//
	//参数值
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value" form:"value"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSyncTaskRequest_Kwargs) Descriptor 

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

func (*CreateSyncTaskRequest_Kwargs) GetKey 

func (m *CreateSyncTaskRequest_Kwargs) GetKey() string

func (*CreateSyncTaskRequest_Kwargs) GetSep 

func (m *CreateSyncTaskRequest_Kwargs) GetSep() string

func (*CreateSyncTaskRequest_Kwargs) GetValue 

func (m *CreateSyncTaskRequest_Kwargs) GetValue() string

func (*CreateSyncTaskRequest_Kwargs) ProtoMessage 

func (*CreateSyncTaskRequest_Kwargs) ProtoMessage()

func (*CreateSyncTaskRequest_Kwargs) Reset 

func (m *CreateSyncTaskRequest_Kwargs) Reset()

func (*CreateSyncTaskRequest_Kwargs) String 

func (m *CreateSyncTaskRequest_Kwargs) String() string

func (*CreateSyncTaskRequest_Kwargs) Validate 

func (this *CreateSyncTaskRequest_Kwargs) Validate() error

func (*CreateSyncTaskRequest_Kwargs) XXX_DiscardUnknown 

func (m *CreateSyncTaskRequest_Kwargs) XXX_DiscardUnknown()

func (*CreateSyncTaskRequest_Kwargs) XXX_Marshal 

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

func (*CreateSyncTaskRequest_Kwargs) XXX_Merge 

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

func (*CreateSyncTaskRequest_Kwargs) XXX_Size 

func (m *CreateSyncTaskRequest_Kwargs) XXX_Size() int

func (*CreateSyncTaskRequest_Kwargs) XXX_Unmarshal 

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

type CreateSyncTaskRequest_Targets 

type CreateSyncTaskRequest_Targets struct {
	//
	//执行目标主机instanceId
	InstanceId           string   `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSyncTaskRequest_Targets) Descriptor 

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

func (*CreateSyncTaskRequest_Targets) GetInstanceId 

func (m *CreateSyncTaskRequest_Targets) GetInstanceId() string

func (*CreateSyncTaskRequest_Targets) ProtoMessage 

func (*CreateSyncTaskRequest_Targets) ProtoMessage()

func (*CreateSyncTaskRequest_Targets) Reset 

func (m *CreateSyncTaskRequest_Targets) Reset()

func (*CreateSyncTaskRequest_Targets) String 

func (m *CreateSyncTaskRequest_Targets) String() string

func (*CreateSyncTaskRequest_Targets) Validate 

func (this *CreateSyncTaskRequest_Targets) Validate() error

func (*CreateSyncTaskRequest_Targets) XXX_DiscardUnknown 

func (m *CreateSyncTaskRequest_Targets) XXX_DiscardUnknown()

func (*CreateSyncTaskRequest_Targets) XXX_Marshal 

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

func (*CreateSyncTaskRequest_Targets) XXX_Merge 

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

func (*CreateSyncTaskRequest_Targets) XXX_Size 

func (m *CreateSyncTaskRequest_Targets) XXX_Size() int

func (*CreateSyncTaskRequest_Targets) XXX_Unmarshal 

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

type CreateSyncTaskResponse 

type CreateSyncTaskResponse struct {
	//
	//执行结果
	TargetsLog           []*CreateSyncTaskResponse_TargetsLog `protobuf:"bytes,1,rep,name=targetsLog,proto3" json:"targetsLog" form:"targetsLog"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

CreateSyncTask返回

func (*CreateSyncTaskResponse) Descriptor 

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

func (*CreateSyncTaskResponse) GetTargetsLog 

func (m *CreateSyncTaskResponse) GetTargetsLog() []*CreateSyncTaskResponse_TargetsLog

func (*CreateSyncTaskResponse) ProtoMessage 

func (*CreateSyncTaskResponse) ProtoMessage()

func (*CreateSyncTaskResponse) Reset 

func (m *CreateSyncTaskResponse) Reset()

func (*CreateSyncTaskResponse) String 

func (m *CreateSyncTaskResponse) String() string

func (*CreateSyncTaskResponse) Validate 

func (this *CreateSyncTaskResponse) Validate() error

func (*CreateSyncTaskResponse) XXX_DiscardUnknown 

func (m *CreateSyncTaskResponse) XXX_DiscardUnknown()

func (*CreateSyncTaskResponse) XXX_Marshal 

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

func (*CreateSyncTaskResponse) XXX_Merge 

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

func (*CreateSyncTaskResponse) XXX_Size 

func (m *CreateSyncTaskResponse) XXX_Size() int

func (*CreateSyncTaskResponse) XXX_Unmarshal 

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

type CreateSyncTaskResponseWrapper 

type CreateSyncTaskResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *CreateSyncTaskResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

CreateSyncTaskApi返回

func (*CreateSyncTaskResponseWrapper) Descriptor 

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

func (*CreateSyncTaskResponseWrapper) GetCode 

func (m *CreateSyncTaskResponseWrapper) GetCode() int32

func (*CreateSyncTaskResponseWrapper) GetCodeExplain 

func (m *CreateSyncTaskResponseWrapper) GetCodeExplain() string

func (*CreateSyncTaskResponseWrapper) GetData 

func (m *CreateSyncTaskResponseWrapper) GetData() *CreateSyncTaskResponse

func (*CreateSyncTaskResponseWrapper) GetError 

func (m *CreateSyncTaskResponseWrapper) GetError() string

func (*CreateSyncTaskResponseWrapper) ProtoMessage 

func (*CreateSyncTaskResponseWrapper) ProtoMessage()

func (*CreateSyncTaskResponseWrapper) Reset 

func (m *CreateSyncTaskResponseWrapper) Reset()

func (*CreateSyncTaskResponseWrapper) String 

func (m *CreateSyncTaskResponseWrapper) String() string

func (*CreateSyncTaskResponseWrapper) Validate 

func (this *CreateSyncTaskResponseWrapper) Validate() error

func (*CreateSyncTaskResponseWrapper) XXX_DiscardUnknown 

func (m *CreateSyncTaskResponseWrapper) XXX_DiscardUnknown()

func (*CreateSyncTaskResponseWrapper) XXX_Marshal 

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

func (*CreateSyncTaskResponseWrapper) XXX_Merge 

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

func (*CreateSyncTaskResponseWrapper) XXX_Size 

func (m *CreateSyncTaskResponseWrapper) XXX_Size() int

func (*CreateSyncTaskResponseWrapper) XXX_Unmarshal 

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

type CreateSyncTaskResponse_TargetsLog 

type CreateSyncTaskResponse_TargetsLog struct {
	//
	//执行机器instanceId
	Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target" form:"target"`
	//
	//错误码
	Code int32 `protobuf:"varint,2,opt,name=code,proto3" json:"code" form:"code"`
	//
	//执行输出
	Output string `protobuf:"bytes,3,opt,name=output,proto3" json:"output" form:"output"`
	//
	//json格式化的执行输出
	JsonOutput           *types.Struct `protobuf:"bytes,4,opt,name=jsonOutput,proto3" json:"jsonOutput" form:"jsonOutput"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CreateSyncTaskResponse_TargetsLog) Descriptor 

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

func (*CreateSyncTaskResponse_TargetsLog) GetCode 

func (m *CreateSyncTaskResponse_TargetsLog) GetCode() int32

func (*CreateSyncTaskResponse_TargetsLog) GetJsonOutput 

func (m *CreateSyncTaskResponse_TargetsLog) GetJsonOutput() *types.Struct

func (*CreateSyncTaskResponse_TargetsLog) GetOutput 

func (m *CreateSyncTaskResponse_TargetsLog) GetOutput() string

func (*CreateSyncTaskResponse_TargetsLog) GetTarget 

func (m *CreateSyncTaskResponse_TargetsLog) GetTarget() string

func (*CreateSyncTaskResponse_TargetsLog) ProtoMessage 

func (*CreateSyncTaskResponse_TargetsLog) ProtoMessage()

func (*CreateSyncTaskResponse_TargetsLog) Reset 

func (m *CreateSyncTaskResponse_TargetsLog) Reset()

func (*CreateSyncTaskResponse_TargetsLog) String 

func (m *CreateSyncTaskResponse_TargetsLog) String() string

func (*CreateSyncTaskResponse_TargetsLog) Validate 

func (this *CreateSyncTaskResponse_TargetsLog) Validate() error

func (*CreateSyncTaskResponse_TargetsLog) XXX_DiscardUnknown 

func (m *CreateSyncTaskResponse_TargetsLog) XXX_DiscardUnknown()

func (*CreateSyncTaskResponse_TargetsLog) XXX_Marshal 

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

func (*CreateSyncTaskResponse_TargetsLog) XXX_Merge 

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

func (*CreateSyncTaskResponse_TargetsLog) XXX_Size 

func (m *CreateSyncTaskResponse_TargetsLog) XXX_Size() int

func (*CreateSyncTaskResponse_TargetsLog) XXX_Unmarshal 

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

type Service 

type Service interface {
	CreateSyncTask(context.Context, *CreateSyncTaskRequest) (*CreateSyncTaskResponse, error)
}

Service is the server API for task service.

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.