go_micro_srv_order

package
v2.3.3 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_order_order_proto protoreflect.FileDescriptor

Functions

func NewOrderEndpoints 

func NewOrderEndpoints() []*api.Endpoint

func RegisterOrderHandler 

func RegisterOrderHandler(s server.Server, hdlr OrderHandler, opts ...server.HandlerOption) error

Types

type CancelReq 

type CancelReq struct {
	Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelReq) Descriptor deprecated 

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

Deprecated: Use CancelReq.ProtoReflect.Descriptor instead.

func (*CancelReq) GetIndex 

func (x *CancelReq) GetIndex() uint32

func (*CancelReq) ProtoMessage 

func (*CancelReq) ProtoMessage()

func (*CancelReq) ProtoReflect 

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

func (*CancelReq) Reset 

func (x *CancelReq) Reset()

func (*CancelReq) String 

func (x *CancelReq) String() string

type MMessage 

type MMessage struct {
	Index    uint32   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Function uint32   `protobuf:"varint,2,opt,name=function,proto3" json:"function,omitempty"`
	ParNo    uint32   `protobuf:"varint,3,opt,name=parNo,proto3" json:"parNo,omitempty"`
	Params   []uint32 `protobuf:"varint,4,rep,packed,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*MMessage) Descriptor deprecated 

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

Deprecated: Use MMessage.ProtoReflect.Descriptor instead.

func (*MMessage) GetFunction 

func (x *MMessage) GetFunction() uint32

func (*MMessage) GetIndex 

func (x *MMessage) GetIndex() uint32

func (*MMessage) GetParNo 

func (x *MMessage) GetParNo() uint32

func (*MMessage) GetParams 

func (x *MMessage) GetParams() []uint32

func (*MMessage) ProtoMessage 

func (*MMessage) ProtoMessage()

func (*MMessage) ProtoReflect 

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

func (*MMessage) Reset 

func (x *MMessage) Reset()

func (*MMessage) String 

func (x *MMessage) String() string

type OrderHandler 

type OrderHandler interface {
	//取消任务
	CancelTask(context.Context, *CancelReq, *Response) error
	//修改参数
	UpdateTask(context.Context, *UpdateReq, *Response) error
	SendQAMessage(context.Context, *QAMessage, *Response) error
	SendQBMessage(context.Context, *QBMessage, *Response) error
	SendMMessage(context.Context, *MMessage, *Response) error
	HostIsConnected(context.Context, *Request, *Response) error
}

type OrderService 

type OrderService interface {
	//取消任务
	CancelTask(ctx context.Context, in *CancelReq, opts ...client.CallOption) (*Response, error)
	//修改参数
	UpdateTask(ctx context.Context, in *UpdateReq, opts ...client.CallOption) (*Response, error)
	SendQAMessage(ctx context.Context, in *QAMessage, opts ...client.CallOption) (*Response, error)
	SendQBMessage(ctx context.Context, in *QBMessage, opts ...client.CallOption) (*Response, error)
	SendMMessage(ctx context.Context, in *MMessage, opts ...client.CallOption) (*Response, error)
	HostIsConnected(ctx context.Context, in *Request, opts ...client.CallOption) (*Response, error)
}

func NewOrderService 

func NewOrderService(name string, c client.Client) OrderService

type QAMessage 

type QAMessage struct {
	TsID     uint32   `protobuf:"varint,1,opt,name=tsID,proto3" json:"tsID,omitempty"`
	Priority uint32   `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	Params   []uint32 `protobuf:"varint,3,rep,packed,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*QAMessage) Descriptor deprecated 

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

Deprecated: Use QAMessage.ProtoReflect.Descriptor instead.

func (*QAMessage) GetParams 

func (x *QAMessage) GetParams() []uint32

func (*QAMessage) GetPriority 

func (x *QAMessage) GetPriority() uint32

func (*QAMessage) GetTsID 

func (x *QAMessage) GetTsID() uint32

func (*QAMessage) ProtoMessage 

func (*QAMessage) ProtoMessage()

func (*QAMessage) ProtoReflect 

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

func (*QAMessage) Reset 

func (x *QAMessage) Reset()

func (*QAMessage) String 

func (x *QAMessage) String() string

type QBMessage 

type QBMessage struct {
	TsID     uint32   `protobuf:"varint,1,opt,name=tsID,proto3" json:"tsID,omitempty"`
	Priority uint32   `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	Code     uint32   `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	Ikey     uint32   `protobuf:"varint,4,opt,name=ikey,proto3" json:"ikey,omitempty"`
	Params   []uint32 `protobuf:"varint,5,rep,packed,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*QBMessage) Descriptor deprecated 

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

Deprecated: Use QBMessage.ProtoReflect.Descriptor instead.

func (*QBMessage) GetCode 

func (x *QBMessage) GetCode() uint32

func (*QBMessage) GetIkey 

func (x *QBMessage) GetIkey() uint32

func (*QBMessage) GetParams 

func (x *QBMessage) GetParams() []uint32

func (*QBMessage) GetPriority 

func (x *QBMessage) GetPriority() uint32

func (*QBMessage) GetTsID 

func (x *QBMessage) GetTsID() uint32

func (*QBMessage) ProtoMessage 

func (*QBMessage) ProtoMessage()

func (*QBMessage) ProtoReflect 

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

func (*QBMessage) Reset 

func (x *QBMessage) Reset()

func (*QBMessage) String 

func (x *QBMessage) String() string

type Request 

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

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

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

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) GetRes 

func (x *Response) GetRes() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Task 

type Task struct {
	TsId     uint32  `protobuf:"varint,1,opt,name=tsId,proto3" json:"tsId,omitempty"`
	Priority uint32  `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	Ikey     uint32  `protobuf:"varint,3,opt,name=ikey,proto3" json:"ikey,omitempty"`
	Params   []int32 `protobuf:"varint,4,rep,packed,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetIkey 

func (x *Task) GetIkey() uint32

func (*Task) GetParams 

func (x *Task) GetParams() []int32

func (*Task) GetPriority 

func (x *Task) GetPriority() uint32

func (*Task) GetTsId 

func (x *Task) GetTsId() uint32

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type UpdateReq 

type UpdateReq struct {
	Index  uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`   //调度系统的任务编号
	ParaNo uint32 `protobuf:"varint,2,opt,name=paraNo,proto3" json:"paraNo,omitempty"` //参数索引
	Value  uint32 `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`   //参数值
	// contains filtered or unexported fields
}

func (*UpdateReq) Descriptor deprecated 

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

Deprecated: Use UpdateReq.ProtoReflect.Descriptor instead.

func (*UpdateReq) GetIndex 

func (x *UpdateReq) GetIndex() uint32

func (*UpdateReq) GetParaNo 

func (x *UpdateReq) GetParaNo() uint32

func (*UpdateReq) GetValue 

func (x *UpdateReq) GetValue() uint32

func (*UpdateReq) ProtoMessage 

func (*UpdateReq) ProtoMessage()

func (*UpdateReq) ProtoReflect 

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

func (*UpdateReq) Reset 

func (x *UpdateReq) Reset()

func (*UpdateReq) String 

func (x *UpdateReq) 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.