go_micro_srv_system

Documentation

Index

• Variables
• func NewSystemEndpoints() []*api.Endpoint
• func RegisterSystemHandler(s server.Server, hdlr SystemHandler, opts ...server.HandlerOption) error
• type ParamReq
  • func (*ParamReq) Descriptor() ([]byte, []int)
  • func (*ParamReq) ProtoMessage()
  • func (x *ParamReq) ProtoReflect() protoreflect.Message
  • func (x *ParamReq) Reset()
  • func (x *ParamReq) String() string
• type Params
  • func (*Params) Descriptor() ([]byte, []int)
  • func (x *Params) GetIgnoreReply() bool
  • func (x *Params) GetServerIp() string
  • func (x *Params) GetServerPort() uint32
  • func (*Params) ProtoMessage()
  • func (x *Params) ProtoReflect() protoreflect.Message
  • func (x *Params) Reset()
  • func (x *Params) String() string
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (x *Request) GetCode() Request_OperationCode
  • func (*Request) ProtoMessage()
  • func (x *Request) ProtoReflect() protoreflect.Message
  • func (x *Request) Reset()
  • func (x *Request) String() string
• type Request_OperationCode
  • func (Request_OperationCode) Descriptor() protoreflect.EnumDescriptor
  • func (x Request_OperationCode) Enum() *Request_OperationCode
  • func (Request_OperationCode) EnumDescriptor() ([]byte, []int)
  • func (x Request_OperationCode) Number() protoreflect.EnumNumber
  • func (x Request_OperationCode) String() string
  • func (Request_OperationCode) Type() protoreflect.EnumType
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (x *Response) GetMessage() string
  • func (x *Response) GetRes() bool
  • func (*Response) ProtoMessage()
  • func (x *Response) ProtoReflect() protoreflect.Message
  • func (x *Response) Reset()
  • func (x *Response) String() string
• type SystemHandler
• type SystemService
  • func NewSystemService(name string, c client.Client) SystemService

Variables

var (
	Request_OperationCode_name = map[int32]string{
		0: "Stop",
		1: "Start",
		2: "Restart",
	}
	Request_OperationCode_value = map[string]int32{
		"Stop":    0,
		"Start":   1,
		"Restart": 2,
	}
)

Enum value maps for Request_OperationCode.

var File_proto_system_system_proto protoreflect.FileDescriptor

Functions

func NewSystemEndpoints

func NewSystemEndpoints() []*api.Endpoint

func RegisterSystemHandler

func RegisterSystemHandler(s server.Server, hdlr SystemHandler, opts ...server.HandlerOption) error

Types

type ParamReq

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

func (*ParamReq) Descriptor

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

Deprecated: Use ParamReq.ProtoReflect.Descriptor instead.

func (*ParamReq) ProtoMessage

func (*ParamReq) ProtoMessage()

func (*ParamReq) ProtoReflect

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

func (*ParamReq) Reset

func (x *ParamReq) Reset()

func (*ParamReq) String

func (x *ParamReq) String() string

type Params

type Params struct {
	ServerIp    string `protobuf:"bytes,1,opt,name=serverIp,proto3" json:"serverIp,omitempty"`
	ServerPort  uint32 `protobuf:"varint,2,opt,name=serverPort,proto3" json:"serverPort,omitempty"`
	IgnoreReply bool   `protobuf:"varint,3,opt,name=ignoreReply,proto3" json:"ignoreReply,omitempty"`
	// contains filtered or unexported fields
}

func (*Params) Descriptor

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

Deprecated: Use Params.ProtoReflect.Descriptor instead.

func (*Params) GetIgnoreReply

func (x *Params) GetIgnoreReply() bool

func (*Params) GetServerIp

func (x *Params) GetServerIp() string

func (*Params) GetServerPort

func (x *Params) GetServerPort() uint32

func (*Params) ProtoMessage

func (*Params) ProtoMessage()

func (*Params) ProtoReflect

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

func (*Params) Reset

func (x *Params) Reset()

func (*Params) String

func (x *Params) String() string

type Request

type Request struct {
	Code Request_OperationCode `protobuf:"varint,1,opt,name=code,proto3,enum=go.micro.srv.agv.system.Request_OperationCode" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetCode

func (x *Request) GetCode() Request_OperationCode

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 Request_OperationCode

type Request_OperationCode int32

const (
	Request_Stop    Request_OperationCode = 0 //停止系统连接//
	Request_Start   Request_OperationCode = 1 //开启系统连接//
	Request_Restart Request_OperationCode = 2 //重启系统连接//
)

func (Request_OperationCode) Descriptor

func (Request_OperationCode) Descriptor() protoreflect.EnumDescriptor

func (Request_OperationCode) Enum

func (x Request_OperationCode) Enum() *Request_OperationCode

func (Request_OperationCode) EnumDescriptor

func (Request_OperationCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use Request_OperationCode.Descriptor instead.

func (Request_OperationCode) Number

func (x Request_OperationCode) Number() protoreflect.EnumNumber

func (Request_OperationCode) String

func (x Request_OperationCode) String() string

func (Request_OperationCode) Type

func (Request_OperationCode) Type() protoreflect.EnumType

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

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 SystemHandler

type SystemHandler interface {
	//更新参数，调度系统的IP地址和端口//
	UpdateParam(context.Context, *Params, *Response) error
	//获取系统参数
	GetParam(context.Context, *ParamReq, *Params) error
	//系统操作//
	SystemOperation(context.Context, *Request, *Response) error
}

type SystemService

type SystemService interface {
	//更新参数，调度系统的IP地址和端口//
	UpdateParam(ctx context.Context, in *Params, opts ...client.CallOption) (*Response, error)
	//获取系统参数
	GetParam(ctx context.Context, in *ParamReq, opts ...client.CallOption) (*Params, error)
	//系统操作//
	SystemOperation(ctx context.Context, in *Request, opts ...client.CallOption) (*Response, error)
}

func NewSystemService

func NewSystemService(name string, c client.Client) SystemService