powerpb

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: May 22, 2020 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Package powerpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var ModuleTypes_name = map[int32]string{
	0:  "UnknownModuleType",
	1:  "Main",
	2:  "EscPos",
	3:  "Screen",
	4:  "Sensor",
	5:  "Speech",
	6:  "Lights",
	7:  "Expression",
	8:  "Navigator",
	9:  "Motion",
	10: "Amplifier",
}
View Source 
var ModuleTypes_value = map[string]int32{
	"UnknownModuleType": 0,
	"Main":              1,
	"EscPos":            2,
	"Screen":            3,
	"Sensor":            4,
	"Speech":            5,
	"Lights":            6,
	"Expression":        7,
	"Navigator":         8,
	"Motion":            9,
	"Amplifier":         10,
}

Functions

func RegisterPowerServiceHandler 

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

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

func RegisterPowerServiceHandlerClient 

func RegisterPowerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PowerServiceClient) error

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

func RegisterPowerServiceHandlerFromEndpoint 

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

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

func RegisterPowerServiceHandlerServer 

func RegisterPowerServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PowerServiceServer) error

RegisterPowerServiceHandlerServer registers the http handlers for service PowerService to "mux". UnaryRPC :call PowerServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterPowerServiceServer 

func RegisterPowerServiceServer(s *grpc.Server, srv PowerServiceServer)

Types

type GetPowerStatusRequest 

type GetPowerStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPowerStatusRequest) Descriptor 

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

func (*GetPowerStatusRequest) ProtoMessage 

func (*GetPowerStatusRequest) ProtoMessage()

func (*GetPowerStatusRequest) Reset 

func (m *GetPowerStatusRequest) Reset()

func (*GetPowerStatusRequest) String 

func (m *GetPowerStatusRequest) String() string

func (*GetPowerStatusRequest) XXX_DiscardUnknown 

func (m *GetPowerStatusRequest) XXX_DiscardUnknown()

func (*GetPowerStatusRequest) XXX_Marshal 

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

func (*GetPowerStatusRequest) XXX_Merge 

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

func (*GetPowerStatusRequest) XXX_Size 

func (m *GetPowerStatusRequest) XXX_Size() int

func (*GetPowerStatusRequest) XXX_Unmarshal 

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

type GetPowerStatusResponse 

type GetPowerStatusResponse struct {
	PowerStatus          *PowerStatus `protobuf:"bytes,1,opt,name=power_status,json=powerStatus,proto3" json:"power_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetPowerStatusResponse) Descriptor 

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

func (*GetPowerStatusResponse) GetPowerStatus 

func (m *GetPowerStatusResponse) GetPowerStatus() *PowerStatus

func (*GetPowerStatusResponse) ProtoMessage 

func (*GetPowerStatusResponse) ProtoMessage()

func (*GetPowerStatusResponse) Reset 

func (m *GetPowerStatusResponse) Reset()

func (*GetPowerStatusResponse) String 

func (m *GetPowerStatusResponse) String() string

func (*GetPowerStatusResponse) XXX_DiscardUnknown 

func (m *GetPowerStatusResponse) XXX_DiscardUnknown()

func (*GetPowerStatusResponse) XXX_Marshal 

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

func (*GetPowerStatusResponse) XXX_Merge 

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

func (*GetPowerStatusResponse) XXX_Size 

func (m *GetPowerStatusResponse) XXX_Size() int

func (*GetPowerStatusResponse) XXX_Unmarshal 

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

type ModuleTypes 

type ModuleTypes int32

模块类型枚举 

const (
	ModuleTypes_UnknownModuleType ModuleTypes = 0
	ModuleTypes_Main              ModuleTypes = 1
	ModuleTypes_EscPos            ModuleTypes = 2
	ModuleTypes_Screen            ModuleTypes = 3
	ModuleTypes_Sensor            ModuleTypes = 4
	ModuleTypes_Speech            ModuleTypes = 5
	ModuleTypes_Lights            ModuleTypes = 6
	ModuleTypes_Expression        ModuleTypes = 7
	ModuleTypes_Navigator         ModuleTypes = 8
	ModuleTypes_Motion            ModuleTypes = 9
	ModuleTypes_Amplifier         ModuleTypes = 10
)

func (ModuleTypes) EnumDescriptor 

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

func (ModuleTypes) String 

func (x ModuleTypes) String() string

type PowerServiceClient 

type PowerServiceClient interface {
	// GetPowerStatus 监听电源状态
	//
	// 开发管理平台功能参考: http://10.10.10.2/power
	GetPowerStatus(ctx context.Context, in *GetPowerStatusRequest, opts ...grpc.CallOption) (PowerService_GetPowerStatusClient, error)
	// Reboot 内部模块的电源进行断电方式重启
	Reboot(ctx context.Context, in *RebootRequest, opts ...grpc.CallOption) (*RebootResponse, error)
	// States 获取电源模块状态
	States(ctx context.Context, in *StatesRequest, opts ...grpc.CallOption) (*StatesResponse, error)
	// Switch 控制内部模块电源的开关
	Switch(ctx context.Context, in *SwitchRequest, opts ...grpc.CallOption) (*SwitchResponse, error)
}

PowerServiceClient is the client API for PowerService service.

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

func NewPowerServiceClient 

func NewPowerServiceClient(cc grpc.ClientConnInterface) PowerServiceClient

type PowerServiceServer 

type PowerServiceServer interface {
	// GetPowerStatus 监听电源状态
	//
	// 开发管理平台功能参考: http://10.10.10.2/power
	GetPowerStatus(*GetPowerStatusRequest, PowerService_GetPowerStatusServer) error
	// Reboot 内部模块的电源进行断电方式重启
	Reboot(context.Context, *RebootRequest) (*RebootResponse, error)
	// States 获取电源模块状态
	States(context.Context, *StatesRequest) (*StatesResponse, error)
	// Switch 控制内部模块电源的开关
	Switch(context.Context, *SwitchRequest) (*SwitchResponse, error)
}

PowerServiceServer is the server API for PowerService service.

type PowerService_GetPowerStatusClient 

type PowerService_GetPowerStatusClient interface {
	Recv() (*GetPowerStatusResponse, error)
	grpc.ClientStream
}

type PowerService_GetPowerStatusServer 

type PowerService_GetPowerStatusServer interface {
	Send(*GetPowerStatusResponse) error
	grpc.ServerStream
}

type PowerStatus 

type PowerStatus struct {
	Level      uint32 `protobuf:"varint,1,opt,name=level,proto3" json:"level,omitempty"`
	IsCharging bool   `protobuf:"varint,2,opt,name=is_charging,json=isCharging,proto3" json:"is_charging,omitempty"`
	// 设备状态
	// 已作废，请使用States方法获取
	Devices map[string]bool `` // Deprecated: Do not use.
	/* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PowerStatus) Descriptor 

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

func (*PowerStatus) GetDevices deprecated 

func (m *PowerStatus) GetDevices() map[string]bool

Deprecated: Do not use.

func (*PowerStatus) GetIsCharging 

func (m *PowerStatus) GetIsCharging() bool

func (*PowerStatus) GetLevel 

func (m *PowerStatus) GetLevel() uint32

func (*PowerStatus) ProtoMessage 

func (*PowerStatus) ProtoMessage()

func (*PowerStatus) Reset 

func (m *PowerStatus) Reset()

func (*PowerStatus) String 

func (m *PowerStatus) String() string

func (*PowerStatus) XXX_DiscardUnknown 

func (m *PowerStatus) XXX_DiscardUnknown()

func (*PowerStatus) XXX_Marshal 

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

func (*PowerStatus) XXX_Merge 

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

func (*PowerStatus) XXX_Size 

func (m *PowerStatus) XXX_Size() int

func (*PowerStatus) XXX_Unmarshal 

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

type RebootRequest 

type RebootRequest struct {
	// 所有模块重启(目前仅支持整机重启)
	All                  bool     `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RebootRequest) Descriptor 

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

func (*RebootRequest) GetAll 

func (m *RebootRequest) GetAll() bool

func (*RebootRequest) ProtoMessage 

func (*RebootRequest) ProtoMessage()

func (*RebootRequest) Reset 

func (m *RebootRequest) Reset()

func (*RebootRequest) String 

func (m *RebootRequest) String() string

func (*RebootRequest) XXX_DiscardUnknown 

func (m *RebootRequest) XXX_DiscardUnknown()

func (*RebootRequest) XXX_Marshal 

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

func (*RebootRequest) XXX_Merge 

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

func (*RebootRequest) XXX_Size 

func (m *RebootRequest) XXX_Size() int

func (*RebootRequest) XXX_Unmarshal 

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

type RebootResponse 

type RebootResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RebootResponse) Descriptor 

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

func (*RebootResponse) ProtoMessage 

func (*RebootResponse) ProtoMessage()

func (*RebootResponse) Reset 

func (m *RebootResponse) Reset()

func (*RebootResponse) String 

func (m *RebootResponse) String() string

func (*RebootResponse) XXX_DiscardUnknown 

func (m *RebootResponse) XXX_DiscardUnknown()

func (*RebootResponse) XXX_Marshal 

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

func (*RebootResponse) XXX_Merge 

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

func (*RebootResponse) XXX_Size 

func (m *RebootResponse) XXX_Size() int

func (*RebootResponse) XXX_Unmarshal 

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

type State 

type State struct {
	// 模块类型
	Module ModuleTypes `protobuf:"varint,1,opt,name=module,proto3,enum=powerService.ModuleTypes" json:"module,omitempty"`
	// 当前模块是否供电
	IsOn bool `protobuf:"varint,2,opt,name=is_on,json=isOn,proto3" json:"is_on,omitempty"`
	// 触发关闭供电倒计时（秒）
	// -1为未配置或已失效
	OffAfter int32 `protobuf:"varint,4,opt,name=off_after,json=offAfter,proto3" json:"off_after,omitempty"`
	// 触发恢复供电倒计时（秒）
	// -1为未配置或已失效
	OnAfter              int32    `protobuf:"varint,3,opt,name=on_after,json=onAfter,proto3" json:"on_after,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*State) Descriptor 

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

func (*State) GetIsOn 

func (m *State) GetIsOn() bool

func (*State) GetModule 

func (m *State) GetModule() ModuleTypes

func (*State) GetOffAfter 

func (m *State) GetOffAfter() int32

func (*State) GetOnAfter 

func (m *State) GetOnAfter() int32

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) String 

func (m *State) String() string

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

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

func (*State) XXX_Merge 

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

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

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

type StatesRequest 

type StatesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatesRequest) Descriptor 

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

func (*StatesRequest) ProtoMessage 

func (*StatesRequest) ProtoMessage()

func (*StatesRequest) Reset 

func (m *StatesRequest) Reset()

func (*StatesRequest) String 

func (m *StatesRequest) String() string

func (*StatesRequest) XXX_DiscardUnknown 

func (m *StatesRequest) XXX_DiscardUnknown()

func (*StatesRequest) XXX_Marshal 

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

func (*StatesRequest) XXX_Merge 

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

func (*StatesRequest) XXX_Size 

func (m *StatesRequest) XXX_Size() int

func (*StatesRequest) XXX_Unmarshal 

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

type StatesResponse 

type StatesResponse struct {
	States               []*State `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatesResponse) Descriptor 

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

func (*StatesResponse) GetStates 

func (m *StatesResponse) GetStates() []*State

func (*StatesResponse) ProtoMessage 

func (*StatesResponse) ProtoMessage()

func (*StatesResponse) Reset 

func (m *StatesResponse) Reset()

func (*StatesResponse) String 

func (m *StatesResponse) String() string

func (*StatesResponse) XXX_DiscardUnknown 

func (m *StatesResponse) XXX_DiscardUnknown()

func (*StatesResponse) XXX_Marshal 

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

func (*StatesResponse) XXX_Merge 

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

func (*StatesResponse) XXX_Size 

func (m *StatesResponse) XXX_Size() int

func (*StatesResponse) XXX_Unmarshal 

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

type SwitchRequest 

type SwitchRequest struct {
	Requests             []*SwitchRequestRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*SwitchRequest) Descriptor 

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

func (*SwitchRequest) GetRequests 

func (m *SwitchRequest) GetRequests() []*SwitchRequestRequest

func (*SwitchRequest) ProtoMessage 

func (*SwitchRequest) ProtoMessage()

func (*SwitchRequest) Reset 

func (m *SwitchRequest) Reset()

func (*SwitchRequest) String 

func (m *SwitchRequest) String() string

func (*SwitchRequest) XXX_DiscardUnknown 

func (m *SwitchRequest) XXX_DiscardUnknown()

func (*SwitchRequest) XXX_Marshal 

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

func (*SwitchRequest) XXX_Merge 

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

func (*SwitchRequest) XXX_Size 

func (m *SwitchRequest) XXX_Size() int

func (*SwitchRequest) XXX_Unmarshal 

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

type SwitchRequestRequest 

type SwitchRequestRequest struct {
	// 模块类型
	Module ModuleTypes `protobuf:"varint,1,opt,name=module,proto3,enum=powerService.ModuleTypes" json:"module,omitempty"`
	// 若干秒后关闭该模块供电
	// -1为未配置 0为立即
	OffAfter int32 `protobuf:"varint,4,opt,name=off_after,json=offAfter,proto3" json:"off_after,omitempty"`
	// 若干秒后恢复该模块供电
	// -1为未配置 0为立即
	OnAfter              int32    `protobuf:"varint,3,opt,name=on_after,json=onAfter,proto3" json:"on_after,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SwitchRequestRequest) Descriptor 

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

func (*SwitchRequestRequest) GetModule 

func (m *SwitchRequestRequest) GetModule() ModuleTypes

func (*SwitchRequestRequest) GetOffAfter 

func (m *SwitchRequestRequest) GetOffAfter() int32

func (*SwitchRequestRequest) GetOnAfter 

func (m *SwitchRequestRequest) GetOnAfter() int32

func (*SwitchRequestRequest) ProtoMessage 

func (*SwitchRequestRequest) ProtoMessage()

func (*SwitchRequestRequest) Reset 

func (m *SwitchRequestRequest) Reset()

func (*SwitchRequestRequest) String 

func (m *SwitchRequestRequest) String() string

func (*SwitchRequestRequest) XXX_DiscardUnknown 

func (m *SwitchRequestRequest) XXX_DiscardUnknown()

func (*SwitchRequestRequest) XXX_Marshal 

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

func (*SwitchRequestRequest) XXX_Merge 

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

func (*SwitchRequestRequest) XXX_Size 

func (m *SwitchRequestRequest) XXX_Size() int

func (*SwitchRequestRequest) XXX_Unmarshal 

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

type SwitchResponse 

type SwitchResponse struct {
	States               []*State `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SwitchResponse) Descriptor 

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

func (*SwitchResponse) GetStates 

func (m *SwitchResponse) GetStates() []*State

func (*SwitchResponse) ProtoMessage 

func (*SwitchResponse) ProtoMessage()

func (*SwitchResponse) Reset 

func (m *SwitchResponse) Reset()

func (*SwitchResponse) String 

func (m *SwitchResponse) String() string

func (*SwitchResponse) XXX_DiscardUnknown 

func (m *SwitchResponse) XXX_DiscardUnknown()

func (*SwitchResponse) XXX_Marshal 

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

func (*SwitchResponse) XXX_Merge 

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

func (*SwitchResponse) XXX_Size 

func (m *SwitchResponse) XXX_Size() int

func (*SwitchResponse) XXX_Unmarshal 

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

type UnimplementedPowerServiceServer 

type UnimplementedPowerServiceServer struct {
}

UnimplementedPowerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPowerServiceServer) GetPowerStatus 

func (*UnimplementedPowerServiceServer) GetPowerStatus(req *GetPowerStatusRequest, srv PowerService_GetPowerStatusServer) error

func (*UnimplementedPowerServiceServer) Reboot 

func (*UnimplementedPowerServiceServer) Reboot(ctx context.Context, req *RebootRequest) (*RebootResponse, error)

func (*UnimplementedPowerServiceServer) States 

func (*UnimplementedPowerServiceServer) States(ctx context.Context, req *StatesRequest) (*StatesResponse, error)

func (*UnimplementedPowerServiceServer) Switch 

func (*UnimplementedPowerServiceServer) Switch(ctx context.Context, req *SwitchRequest) (*SwitchResponse, 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.