proto

package
v0.0.15 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pub_agent_proto protoreflect.FileDescriptor

Functions

func RegisterPubConnectServer 

func RegisterPubConnectServer(s *grpc.Server, srv PubConnectServer)

Types

type PubConnectClient 

type PubConnectClient interface {
	DoWork(ctx context.Context, opts ...grpc.CallOption) (PubConnect_DoWorkClient, error)
	Register(ctx context.Context, in *RegReq, opts ...grpc.CallOption) (*RegResp, error)
	DeRegister(ctx context.Context, in *RegReq, opts ...grpc.CallOption) (*RegResp, error)
}

PubConnectClient is the client API for PubConnect service.

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

func NewPubConnectClient 

func NewPubConnectClient(cc grpc.ClientConnInterface) PubConnectClient

type PubConnectServer 

type PubConnectServer interface {
	DoWork(PubConnect_DoWorkServer) error
	Register(context.Context, *RegReq) (*RegResp, error)
	DeRegister(context.Context, *RegReq) (*RegResp, error)
}

PubConnectServer is the server API for PubConnect service.

type PubConnect_DoWorkClient 

type PubConnect_DoWorkClient interface {
	Send(*WorkDetail) error
	Recv() (*WorkDetail, error)
	grpc.ClientStream
}

type PubConnect_DoWorkServer 

type PubConnect_DoWorkServer interface {
	Send(*WorkDetail) error
	Recv() (*WorkDetail, error)
	grpc.ServerStream
}

type RegReq 

type RegReq struct {
	PriKey  string `protobuf:"bytes,1,opt,name=priKey,proto3" json:"priKey,omitempty"`
	AppName string `protobuf:"bytes,2,opt,name=appName,proto3" json:"appName,omitempty"`
	Uuid    string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"` //注册节点启动uuid
	// contains filtered or unexported fields
}

func (*RegReq) Descriptor deprecated 

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

Deprecated: Use RegReq.ProtoReflect.Descriptor instead.

func (*RegReq) GetAppName 

func (x *RegReq) GetAppName() string

func (*RegReq) GetPriKey 

func (x *RegReq) GetPriKey() string

func (*RegReq) GetUuid 

func (x *RegReq) GetUuid() string

func (*RegReq) ProtoMessage 

func (*RegReq) ProtoMessage()

func (*RegReq) ProtoReflect 

func (x *RegReq) ProtoReflect() protoreflect.Message

func (*RegReq) Reset 

func (x *RegReq) Reset()

func (*RegReq) String 

func (x *RegReq) String() string

type RegResp 

type RegResp struct {
	PriKey string `protobuf:"bytes,1,opt,name=priKey,proto3" json:"priKey,omitempty"`
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Remark string `protobuf:"bytes,3,opt,name=remark,proto3" json:"remark,omitempty"`
	// contains filtered or unexported fields
}

func (*RegResp) Descriptor deprecated 

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

Deprecated: Use RegResp.ProtoReflect.Descriptor instead.

func (*RegResp) GetPriKey 

func (x *RegResp) GetPriKey() string

func (*RegResp) GetRemark 

func (x *RegResp) GetRemark() string

func (*RegResp) GetStatus 

func (x *RegResp) GetStatus() string

func (*RegResp) ProtoMessage 

func (*RegResp) ProtoMessage()

func (*RegResp) ProtoReflect 

func (x *RegResp) ProtoReflect() protoreflect.Message

func (*RegResp) Reset 

func (x *RegResp) Reset()

func (*RegResp) String 

func (x *RegResp) String() string

type UnimplementedPubConnectServer 

type UnimplementedPubConnectServer struct {
}

UnimplementedPubConnectServer can be embedded to have forward compatible implementations.

func (*UnimplementedPubConnectServer) DeRegister 

func (*UnimplementedPubConnectServer) DeRegister(context.Context, *RegReq) (*RegResp, error)

func (*UnimplementedPubConnectServer) DoWork 

func (*UnimplementedPubConnectServer) DoWork(PubConnect_DoWorkServer) error

func (*UnimplementedPubConnectServer) Register 

func (*UnimplementedPubConnectServer) Register(context.Context, *RegReq) (*RegResp, error)

type WorkDetail 

type WorkDetail struct {
	PriKey       string `protobuf:"bytes,1,opt,name=priKey,proto3" json:"priKey,omitempty"`
	AppName      string `protobuf:"bytes,2,opt,name=appName,proto3" json:"appName,omitempty"` // 需要调度的执行器的应用名称
	AppUuid      string `protobuf:"bytes,3,opt,name=appUuid,proto3" json:"appUuid,omitempty"`
	Name         string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`                  // 执行的任务名称
	Uuid         string `protobuf:"bytes,5,opt,name=uuid,proto3" json:"uuid,omitempty"`                  // 执行任务的uid
	Params       string `protobuf:"bytes,6,opt,name=params,proto3" json:"params,omitempty"`              // 执行任务的参数
	RequestTime  int64  `protobuf:"varint,7,opt,name=requestTime,proto3" json:"requestTime,omitempty"`   // 提交任务的时间
	ResponseTime int64  `protobuf:"varint,8,opt,name=responseTime,proto3" json:"responseTime,omitempty"` // 响应任务的时间
	Status       string `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`              // 任务的状态
	Results      string `protobuf:"bytes,10,opt,name=results,proto3" json:"results,omitempty"`           // 查询任务的返回
	ErrCode      int32  `protobuf:"varint,11,opt,name=errCode,proto3" json:"errCode,omitempty"`          // 失败错误吗
	// contains filtered or unexported fields
}

func (*WorkDetail) Descriptor deprecated 

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

Deprecated: Use WorkDetail.ProtoReflect.Descriptor instead.

func (*WorkDetail) GetAppName 

func (x *WorkDetail) GetAppName() string

func (*WorkDetail) GetAppUuid 

func (x *WorkDetail) GetAppUuid() string

func (*WorkDetail) GetErrCode 

func (x *WorkDetail) GetErrCode() int32

func (*WorkDetail) GetName 

func (x *WorkDetail) GetName() string

func (*WorkDetail) GetParams 

func (x *WorkDetail) GetParams() string

func (*WorkDetail) GetPriKey 

func (x *WorkDetail) GetPriKey() string

func (*WorkDetail) GetRequestTime 

func (x *WorkDetail) GetRequestTime() int64

func (*WorkDetail) GetResponseTime 

func (x *WorkDetail) GetResponseTime() int64

func (*WorkDetail) GetResults 

func (x *WorkDetail) GetResults() string

func (*WorkDetail) GetStatus 

func (x *WorkDetail) GetStatus() string

func (*WorkDetail) GetUuid 

func (x *WorkDetail) GetUuid() string

func (*WorkDetail) ProtoMessage 

func (*WorkDetail) ProtoMessage()

func (*WorkDetail) ProtoReflect 

func (x *WorkDetail) ProtoReflect() protoreflect.Message

func (*WorkDetail) Reset 

func (x *WorkDetail) Reset()

func (*WorkDetail) String 

func (x *WorkDetail) String() string

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.