cq_decode

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2021 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Overview

Package cq_decode is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_cq_decode_cq_decode_proto protoreflect.FileDescriptor

Functions

func RegisterDecodeHandler 

func RegisterDecodeHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDecodeHandler registers the http handlers for service Decode to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDecodeHandlerClient 

func RegisterDecodeHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DecodeClient) error

RegisterDecodeHandlerClient registers the http handlers for service Decode to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DecodeClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DecodeClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DecodeClient" to call the correct interceptors.

func RegisterDecodeHandlerFromEndpoint 

func RegisterDecodeHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDecodeHandlerFromEndpoint is same as RegisterDecodeHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDecodeHandlerServer 

func RegisterDecodeHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DecodeServer) error

RegisterDecodeHandlerServer registers the http handlers for service Decode to "mux". UnaryRPC :call DecodeServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDecodeHandlerFromEndpoint instead.

func RegisterDecodeServer 

func RegisterDecodeServer(s *grpc.Server, srv DecodeServer)

Types

type DecodeClient 

type DecodeClient interface {
	//设置解码器输出
	SetOut(ctx context.Context, in *SetOutRequest, opts ...grpc.CallOption) (*SetOutResponse, error)
	//解码器状态获取
	GetState(ctx context.Context, in *StateRequest, opts ...grpc.CallOption) (Decode_GetStateClient, error)
}

DecodeClient is the client API for Decode service.

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

func NewDecodeClient 

func NewDecodeClient(cc grpc.ClientConnInterface) DecodeClient

type DecodeServer 

type DecodeServer interface {
	//设置解码器输出
	SetOut(context.Context, *SetOutRequest) (*SetOutResponse, error)
	//解码器状态获取
	GetState(*StateRequest, Decode_GetStateServer) error
}

DecodeServer is the server API for Decode service.

type Decode_GetStateClient 

type Decode_GetStateClient interface {
	Recv() (*StateResponse, error)
	grpc.ClientStream
}

type Decode_GetStateServer 

type Decode_GetStateServer interface {
	Send(*StateResponse) error
	grpc.ServerStream
}

type Output 

type Output struct {
	Id    uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Value uint32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Output) Descriptor deprecated 

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetId 

func (x *Output) GetId() uint32

func (*Output) GetValue 

func (x *Output) GetValue() uint32

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) ProtoReflect 

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

func (*Output) Reset 

func (x *Output) Reset()

func (*Output) String 

func (x *Output) String() string

type SetOutRequest 

type SetOutRequest struct {
	Id      string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` //4个字节高两位是通讯口端口号,低２位为485站号
	Outputs []*Output `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

设置电磁阀输出请求

func (*SetOutRequest) Descriptor deprecated 

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

Deprecated: Use SetOutRequest.ProtoReflect.Descriptor instead.

func (*SetOutRequest) GetId 

func (x *SetOutRequest) GetId() string

func (*SetOutRequest) GetOutputs 

func (x *SetOutRequest) GetOutputs() []*Output

func (*SetOutRequest) ProtoMessage 

func (*SetOutRequest) ProtoMessage()

func (*SetOutRequest) ProtoReflect 

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

func (*SetOutRequest) Reset 

func (x *SetOutRequest) Reset()

func (*SetOutRequest) String 

func (x *SetOutRequest) String() string

type SetOutResponse 

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

设置电磁阀输出响应

func (*SetOutResponse) Descriptor deprecated 

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

Deprecated: Use SetOutResponse.ProtoReflect.Descriptor instead.

func (*SetOutResponse) ProtoMessage 

func (*SetOutResponse) ProtoMessage()

func (*SetOutResponse) ProtoReflect 

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

func (*SetOutResponse) Reset 

func (x *SetOutResponse) Reset()

func (*SetOutResponse) String 

func (x *SetOutResponse) String() string

type StateRequest 

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

电磁阀状态获取请求

func (*StateRequest) Descriptor deprecated 

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

Deprecated: Use StateRequest.ProtoReflect.Descriptor instead.

func (*StateRequest) ProtoMessage 

func (*StateRequest) ProtoMessage()

func (*StateRequest) ProtoReflect 

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

func (*StateRequest) Reset 

func (x *StateRequest) Reset()

func (*StateRequest) String 

func (x *StateRequest) String() string

type StateResponse 

type StateResponse struct {
	Id      string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` //4个字节高两位是通讯口端口号,低２位为485站号
	Outputs []*Output `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Volt    float32   `protobuf:"fixed32,3,opt,name=volt,proto3" json:"volt,omitempty"` //电压值
	// contains filtered or unexported fields
}

电磁阀状态获取返回

func (*StateResponse) Descriptor deprecated 

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

Deprecated: Use StateResponse.ProtoReflect.Descriptor instead.

func (*StateResponse) GetId 

func (x *StateResponse) GetId() string

func (*StateResponse) GetOutputs 

func (x *StateResponse) GetOutputs() []*Output

func (*StateResponse) GetVolt 

func (x *StateResponse) GetVolt() float32

func (*StateResponse) ProtoMessage 

func (*StateResponse) ProtoMessage()

func (*StateResponse) ProtoReflect 

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

func (*StateResponse) Reset 

func (x *StateResponse) Reset()

func (*StateResponse) String 

func (x *StateResponse) String() string

type UnimplementedDecodeServer 

type UnimplementedDecodeServer struct {
}

UnimplementedDecodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedDecodeServer) GetState 

func (*UnimplementedDecodeServer) GetState(*StateRequest, Decode_GetStateServer) error

func (*UnimplementedDecodeServer) SetOut 

func (*UnimplementedDecodeServer) SetOut(context.Context, *SetOutRequest) (*SetOutResponse, 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.