base

package
v0.0.0-...-3716e7a Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2019 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDiagnosticsServiceServer 

func RegisterDiagnosticsServiceServer(s *grpc.Server, srv DiagnosticsServiceServer)

func RegisterFunctionalServiceServer 

func RegisterFunctionalServiceServer(s *grpc.Server, srv FunctionalServiceServer)

func RegisterNetworkServiceServer 

func RegisterNetworkServiceServer(s *grpc.Server, srv NetworkServiceServer)

func RegisterSystemServiceServer 

func RegisterSystemServiceServer(s *grpc.Server, srv SystemServiceServer)

Types

type ClientId 

type ClientId struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientId) Descriptor 

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

func (*ClientId) GetId 

func (m *ClientId) GetId() string

func (*ClientId) ProtoMessage 

func (*ClientId) ProtoMessage()

func (*ClientId) Reset 

func (m *ClientId) Reset()

func (*ClientId) String 

func (m *ClientId) String() string

func (*ClientId) XXX_DiscardUnknown 

func (m *ClientId) XXX_DiscardUnknown()

func (*ClientId) XXX_Marshal 

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

func (*ClientId) XXX_Merge 

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

func (*ClientId) XXX_Size 

func (m *ClientId) XXX_Size() int

func (*ClientId) XXX_Unmarshal 

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

type Configuration 

type Configuration struct {
	NetworkInfo          []*NetworkInfo `protobuf:"bytes,1,rep,name=networkInfo,proto3" json:"networkInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Configuration) Descriptor 

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

func (*Configuration) GetNetworkInfo 

func (m *Configuration) GetNetworkInfo() []*NetworkInfo

func (*Configuration) ProtoMessage 

func (*Configuration) ProtoMessage()

func (*Configuration) Reset 

func (m *Configuration) Reset()

func (*Configuration) String 

func (m *Configuration) String() string

func (*Configuration) XXX_DiscardUnknown 

func (m *Configuration) XXX_DiscardUnknown()

func (*Configuration) XXX_Marshal 

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

func (*Configuration) XXX_Merge 

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

func (*Configuration) XXX_Size 

func (m *Configuration) XXX_Size() int

func (*Configuration) XXX_Unmarshal 

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

type DiagnosticsRequest 

type DiagnosticsRequest struct {
	UpLink               *SignalId `protobuf:"bytes,1,opt,name=upLink,proto3" json:"upLink,omitempty"`
	DownLink             *SignalId `protobuf:"bytes,2,opt,name=downLink,proto3" json:"downLink,omitempty"`
	ServiceId            []byte    `protobuf:"bytes,3,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	DataIdentifier       []byte    `protobuf:"bytes,4,opt,name=dataIdentifier,proto3" json:"dataIdentifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DiagnosticsRequest) Descriptor 

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

func (*DiagnosticsRequest) GetDataIdentifier 

func (m *DiagnosticsRequest) GetDataIdentifier() []byte
func (m *DiagnosticsRequest) GetDownLink() *SignalId

func (*DiagnosticsRequest) GetServiceId 

func (m *DiagnosticsRequest) GetServiceId() []byte
func (m *DiagnosticsRequest) GetUpLink() *SignalId

func (*DiagnosticsRequest) ProtoMessage 

func (*DiagnosticsRequest) ProtoMessage()

func (*DiagnosticsRequest) Reset 

func (m *DiagnosticsRequest) Reset()

func (*DiagnosticsRequest) String 

func (m *DiagnosticsRequest) String() string

func (*DiagnosticsRequest) XXX_DiscardUnknown 

func (m *DiagnosticsRequest) XXX_DiscardUnknown()

func (*DiagnosticsRequest) XXX_Marshal 

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

func (*DiagnosticsRequest) XXX_Merge 

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

func (*DiagnosticsRequest) XXX_Size 

func (m *DiagnosticsRequest) XXX_Size() int

func (*DiagnosticsRequest) XXX_Unmarshal 

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

type DiagnosticsResponse 

type DiagnosticsResponse struct {
	Raw                  []byte   `protobuf:"bytes,5,opt,name=raw,proto3" json:"raw,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiagnosticsResponse) Descriptor 

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

func (*DiagnosticsResponse) GetRaw 

func (m *DiagnosticsResponse) GetRaw() []byte

func (*DiagnosticsResponse) ProtoMessage 

func (*DiagnosticsResponse) ProtoMessage()

func (*DiagnosticsResponse) Reset 

func (m *DiagnosticsResponse) Reset()

func (*DiagnosticsResponse) String 

func (m *DiagnosticsResponse) String() string

func (*DiagnosticsResponse) XXX_DiscardUnknown 

func (m *DiagnosticsResponse) XXX_DiscardUnknown()

func (*DiagnosticsResponse) XXX_Marshal 

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

func (*DiagnosticsResponse) XXX_Merge 

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

func (*DiagnosticsResponse) XXX_Size 

func (m *DiagnosticsResponse) XXX_Size() int

func (*DiagnosticsResponse) XXX_Unmarshal 

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

type DiagnosticsServiceClient 

type DiagnosticsServiceClient interface {
	// TODO to be implemented
	SendDiagnosticsQuery(ctx context.Context, in *DiagnosticsRequest, opts ...grpc.CallOption) (*DiagnosticsResponse, error)
}

DiagnosticsServiceClient is the client API for DiagnosticsService service.

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

func NewDiagnosticsServiceClient 

func NewDiagnosticsServiceClient(cc *grpc.ClientConn) DiagnosticsServiceClient

type DiagnosticsServiceServer 

type DiagnosticsServiceServer interface {
	// TODO to be implemented
	SendDiagnosticsQuery(context.Context, *DiagnosticsRequest) (*DiagnosticsResponse, error)
}

DiagnosticsServiceServer is the server API for DiagnosticsService service.

type Empty 

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

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type FrameInfo 

type FrameInfo struct {
	SignalInfo           *SignalInfo   `protobuf:"bytes,1,opt,name=signalInfo,proto3" json:"signalInfo,omitempty"`
	ChildInfo            []*SignalInfo `protobuf:"bytes,2,rep,name=childInfo,proto3" json:"childInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*FrameInfo) Descriptor 

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

func (*FrameInfo) GetChildInfo 

func (m *FrameInfo) GetChildInfo() []*SignalInfo

func (*FrameInfo) GetSignalInfo 

func (m *FrameInfo) GetSignalInfo() *SignalInfo

func (*FrameInfo) ProtoMessage 

func (*FrameInfo) ProtoMessage()

func (*FrameInfo) Reset 

func (m *FrameInfo) Reset()

func (*FrameInfo) String 

func (m *FrameInfo) String() string

func (*FrameInfo) XXX_DiscardUnknown 

func (m *FrameInfo) XXX_DiscardUnknown()

func (*FrameInfo) XXX_Marshal 

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

func (*FrameInfo) XXX_Merge 

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

func (*FrameInfo) XXX_Size 

func (m *FrameInfo) XXX_Size() int

func (*FrameInfo) XXX_Unmarshal 

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

type Frames 

type Frames struct {
	Frame                []*FrameInfo `protobuf:"bytes,1,rep,name=frame,proto3" json:"frame,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Frames) Descriptor 

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

func (*Frames) GetFrame 

func (m *Frames) GetFrame() []*FrameInfo

func (*Frames) ProtoMessage 

func (*Frames) ProtoMessage()

func (*Frames) Reset 

func (m *Frames) Reset()

func (*Frames) String 

func (m *Frames) String() string

func (*Frames) XXX_DiscardUnknown 

func (m *Frames) XXX_DiscardUnknown()

func (*Frames) XXX_Marshal 

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

func (*Frames) XXX_Merge 

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

func (*Frames) XXX_Size 

func (m *Frames) XXX_Size() int

func (*Frames) XXX_Unmarshal 

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

type FunctionalServiceClient 

type FunctionalServiceClient interface {
	OpenPassWindow(ctx context.Context, in *ClientId, opts ...grpc.CallOption) (*Empty, error)
	ClosePassWindow(ctx context.Context, in *ClientId, opts ...grpc.CallOption) (*Empty, error)
	SetFanSpeed(ctx context.Context, in *SenderInfo, opts ...grpc.CallOption) (*Empty, error)
	SubscribeToFanSpeed(ctx context.Context, in *SubscriberRequest, opts ...grpc.CallOption) (FunctionalService_SubscribeToFanSpeedClient, error)
}

FunctionalServiceClient is the client API for FunctionalService service.

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

func NewFunctionalServiceClient 

func NewFunctionalServiceClient(cc *grpc.ClientConn) FunctionalServiceClient

type FunctionalServiceServer 

type FunctionalServiceServer interface {
	OpenPassWindow(context.Context, *ClientId) (*Empty, error)
	ClosePassWindow(context.Context, *ClientId) (*Empty, error)
	SetFanSpeed(context.Context, *SenderInfo) (*Empty, error)
	SubscribeToFanSpeed(*SubscriberRequest, FunctionalService_SubscribeToFanSpeedServer) error
}

FunctionalServiceServer is the server API for FunctionalService service.

type FunctionalService_SubscribeToFanSpeedClient 

type FunctionalService_SubscribeToFanSpeedClient interface {
	Recv() (*Value, error)
	grpc.ClientStream
}

type FunctionalService_SubscribeToFanSpeedServer 

type FunctionalService_SubscribeToFanSpeedServer interface {
	Send(*Value) error
	grpc.ServerStream
}

type MetaData 

type MetaData struct {
	Description          string   `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Max                  int32    `protobuf:"varint,5,opt,name=max,proto3" json:"max,omitempty"`
	Min                  int32    `protobuf:"varint,6,opt,name=min,proto3" json:"min,omitempty"`
	Unit                 string   `protobuf:"bytes,7,opt,name=unit,proto3" json:"unit,omitempty"`
	Size                 int32    `protobuf:"varint,8,opt,name=size,proto3" json:"size,omitempty"`
	IsRaw                bool     `protobuf:"varint,9,opt,name=isRaw,proto3" json:"isRaw,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetaData) Descriptor 

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

func (*MetaData) GetDescription 

func (m *MetaData) GetDescription() string

func (*MetaData) GetIsRaw 

func (m *MetaData) GetIsRaw() bool

func (*MetaData) GetMax 

func (m *MetaData) GetMax() int32

func (*MetaData) GetMin 

func (m *MetaData) GetMin() int32

func (*MetaData) GetSize 

func (m *MetaData) GetSize() int32

func (*MetaData) GetUnit 

func (m *MetaData) GetUnit() string

func (*MetaData) ProtoMessage 

func (*MetaData) ProtoMessage()

func (*MetaData) Reset 

func (m *MetaData) Reset()

func (*MetaData) String 

func (m *MetaData) String() string

func (*MetaData) XXX_DiscardUnknown 

func (m *MetaData) XXX_DiscardUnknown()

func (*MetaData) XXX_Marshal 

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

func (*MetaData) XXX_Merge 

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

func (*MetaData) XXX_Size 

func (m *MetaData) XXX_Size() int

func (*MetaData) XXX_Unmarshal 

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

type NameSpace 

type NameSpace struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NameSpace) Descriptor 

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

func (*NameSpace) GetName 

func (m *NameSpace) GetName() string

func (*NameSpace) ProtoMessage 

func (*NameSpace) ProtoMessage()

func (*NameSpace) Reset 

func (m *NameSpace) Reset()

func (*NameSpace) String 

func (m *NameSpace) String() string

func (*NameSpace) XXX_DiscardUnknown 

func (m *NameSpace) XXX_DiscardUnknown()

func (*NameSpace) XXX_Marshal 

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

func (*NameSpace) XXX_Merge 

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

func (*NameSpace) XXX_Size 

func (m *NameSpace) XXX_Size() int

func (*NameSpace) XXX_Unmarshal 

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

type NetworkInfo 

type NetworkInfo struct {
	Namespace            *NameSpace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type                 string     `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description          string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*NetworkInfo) Descriptor 

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

func (*NetworkInfo) GetDescription 

func (m *NetworkInfo) GetDescription() string

func (*NetworkInfo) GetNamespace 

func (m *NetworkInfo) GetNamespace() *NameSpace

func (*NetworkInfo) GetType 

func (m *NetworkInfo) GetType() string

func (*NetworkInfo) ProtoMessage 

func (*NetworkInfo) ProtoMessage()

func (*NetworkInfo) Reset 

func (m *NetworkInfo) Reset()

func (*NetworkInfo) String 

func (m *NetworkInfo) String() string

func (*NetworkInfo) XXX_DiscardUnknown 

func (m *NetworkInfo) XXX_DiscardUnknown()

func (*NetworkInfo) XXX_Marshal 

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

func (*NetworkInfo) XXX_Merge 

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

func (*NetworkInfo) XXX_Size 

func (m *NetworkInfo) XXX_Size() int

func (*NetworkInfo) XXX_Unmarshal 

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

type NetworkServiceClient 

type NetworkServiceClient interface {
	SubscribeToSignals(ctx context.Context, in *SubscriberConfig, opts ...grpc.CallOption) (NetworkService_SubscribeToSignalsClient, error)
	PublishSignals(ctx context.Context, in *PublisherConfig, opts ...grpc.CallOption) (*Empty, error)
	ReadSignals(ctx context.Context, in *SignalIds, opts ...grpc.CallOption) (*Signals, error)
}

NetworkServiceClient is the client API for NetworkService service.

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

func NewNetworkServiceClient 

func NewNetworkServiceClient(cc *grpc.ClientConn) NetworkServiceClient

type NetworkServiceServer 

type NetworkServiceServer interface {
	SubscribeToSignals(*SubscriberConfig, NetworkService_SubscribeToSignalsServer) error
	PublishSignals(context.Context, *PublisherConfig) (*Empty, error)
	ReadSignals(context.Context, *SignalIds) (*Signals, error)
}

NetworkServiceServer is the server API for NetworkService service.

type NetworkService_SubscribeToSignalsClient 

type NetworkService_SubscribeToSignalsClient interface {
	Recv() (*Signals, error)
	grpc.ClientStream
}

type NetworkService_SubscribeToSignalsServer 

type NetworkService_SubscribeToSignalsServer interface {
	Send(*Signals) error
	grpc.ServerStream
}

type PublisherConfig 

type PublisherConfig struct {
	Signals              *Signals  `protobuf:"bytes,1,opt,name=signals,proto3" json:"signals,omitempty"`
	ClientId             *ClientId `protobuf:"bytes,2,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Frequency            int32     `protobuf:"varint,3,opt,name=frequency,proto3" json:"frequency,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PublisherConfig) Descriptor 

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

func (*PublisherConfig) GetClientId 

func (m *PublisherConfig) GetClientId() *ClientId

func (*PublisherConfig) GetFrequency 

func (m *PublisherConfig) GetFrequency() int32

func (*PublisherConfig) GetSignals 

func (m *PublisherConfig) GetSignals() *Signals

func (*PublisherConfig) ProtoMessage 

func (*PublisherConfig) ProtoMessage()

func (*PublisherConfig) Reset 

func (m *PublisherConfig) Reset()

func (*PublisherConfig) String 

func (m *PublisherConfig) String() string

func (*PublisherConfig) XXX_DiscardUnknown 

func (m *PublisherConfig) XXX_DiscardUnknown()

func (*PublisherConfig) XXX_Marshal 

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

func (*PublisherConfig) XXX_Merge 

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

func (*PublisherConfig) XXX_Size 

func (m *PublisherConfig) XXX_Size() int

func (*PublisherConfig) XXX_Unmarshal 

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

type SenderInfo 

type SenderInfo struct {
	ClientId             *ClientId `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Value                *Value    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Frequency            int32     `protobuf:"varint,3,opt,name=frequency,proto3" json:"frequency,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

to stop hammering make same call with frequency 0

func (*SenderInfo) Descriptor 

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

func (*SenderInfo) GetClientId 

func (m *SenderInfo) GetClientId() *ClientId

func (*SenderInfo) GetFrequency 

func (m *SenderInfo) GetFrequency() int32

func (*SenderInfo) GetValue 

func (m *SenderInfo) GetValue() *Value

func (*SenderInfo) ProtoMessage 

func (*SenderInfo) ProtoMessage()

func (*SenderInfo) Reset 

func (m *SenderInfo) Reset()

func (*SenderInfo) String 

func (m *SenderInfo) String() string

func (*SenderInfo) XXX_DiscardUnknown 

func (m *SenderInfo) XXX_DiscardUnknown()

func (*SenderInfo) XXX_Marshal 

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

func (*SenderInfo) XXX_Merge 

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

func (*SenderInfo) XXX_Size 

func (m *SenderInfo) XXX_Size() int

func (*SenderInfo) XXX_Unmarshal 

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

type Signal 

type Signal struct {
	Id *SignalId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*Signal_Integer
	//	*Signal_Double
	//	*Signal_Arbitration
	//	*Signal_Empty
	Payload              isSignal_Payload `protobuf_oneof:"payload"`
	Raw                  []byte           `protobuf:"bytes,5,opt,name=raw,proto3" json:"raw,omitempty"`
	Timestamp            int64            `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Signal) Descriptor 

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

func (*Signal) GetArbitration 

func (m *Signal) GetArbitration() bool

func (*Signal) GetDouble 

func (m *Signal) GetDouble() float64

func (*Signal) GetEmpty 

func (m *Signal) GetEmpty() bool

func (*Signal) GetId 

func (m *Signal) GetId() *SignalId

func (*Signal) GetInteger 

func (m *Signal) GetInteger() int64

func (*Signal) GetPayload 

func (m *Signal) GetPayload() isSignal_Payload

func (*Signal) GetRaw 

func (m *Signal) GetRaw() []byte

func (*Signal) GetTimestamp 

func (m *Signal) GetTimestamp() int64

func (*Signal) ProtoMessage 

func (*Signal) ProtoMessage()

func (*Signal) Reset 

func (m *Signal) Reset()

func (*Signal) String 

func (m *Signal) String() string

func (*Signal) XXX_DiscardUnknown 

func (m *Signal) XXX_DiscardUnknown()

func (*Signal) XXX_Marshal 

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

func (*Signal) XXX_Merge 

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

func (*Signal) XXX_OneofWrappers 

func (*Signal) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Signal) XXX_Size 

func (m *Signal) XXX_Size() int

func (*Signal) XXX_Unmarshal 

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

type SignalId 

type SignalId struct {
	Name                 string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            *NameSpace `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SignalId) Descriptor 

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

func (*SignalId) GetName 

func (m *SignalId) GetName() string

func (*SignalId) GetNamespace 

func (m *SignalId) GetNamespace() *NameSpace

func (*SignalId) ProtoMessage 

func (*SignalId) ProtoMessage()

func (*SignalId) Reset 

func (m *SignalId) Reset()

func (*SignalId) String 

func (m *SignalId) String() string

func (*SignalId) XXX_DiscardUnknown 

func (m *SignalId) XXX_DiscardUnknown()

func (*SignalId) XXX_Marshal 

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

func (*SignalId) XXX_Merge 

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

func (*SignalId) XXX_Size 

func (m *SignalId) XXX_Size() int

func (*SignalId) XXX_Unmarshal 

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

type SignalIds 

type SignalIds struct {
	SignalId             []*SignalId `protobuf:"bytes,1,rep,name=signalId,proto3" json:"signalId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SignalIds) Descriptor 

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

func (*SignalIds) GetSignalId 

func (m *SignalIds) GetSignalId() []*SignalId

func (*SignalIds) ProtoMessage 

func (*SignalIds) ProtoMessage()

func (*SignalIds) Reset 

func (m *SignalIds) Reset()

func (*SignalIds) String 

func (m *SignalIds) String() string

func (*SignalIds) XXX_DiscardUnknown 

func (m *SignalIds) XXX_DiscardUnknown()

func (*SignalIds) XXX_Marshal 

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

func (*SignalIds) XXX_Merge 

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

func (*SignalIds) XXX_Size 

func (m *SignalIds) XXX_Size() int

func (*SignalIds) XXX_Unmarshal 

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

type SignalInfo 

type SignalInfo struct {
	Id                   *SignalId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	MetaData             *MetaData `protobuf:"bytes,2,opt,name=metaData,proto3" json:"metaData,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SignalInfo) Descriptor 

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

func (*SignalInfo) GetId 

func (m *SignalInfo) GetId() *SignalId

func (*SignalInfo) GetMetaData 

func (m *SignalInfo) GetMetaData() *MetaData

func (*SignalInfo) ProtoMessage 

func (*SignalInfo) ProtoMessage()

func (*SignalInfo) Reset 

func (m *SignalInfo) Reset()

func (*SignalInfo) String 

func (m *SignalInfo) String() string

func (*SignalInfo) XXX_DiscardUnknown 

func (m *SignalInfo) XXX_DiscardUnknown()

func (*SignalInfo) XXX_Marshal 

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

func (*SignalInfo) XXX_Merge 

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

func (*SignalInfo) XXX_Size 

func (m *SignalInfo) XXX_Size() int

func (*SignalInfo) XXX_Unmarshal 

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

type Signal_Arbitration 

type Signal_Arbitration struct {
	Arbitration bool `protobuf:"varint,4,opt,name=arbitration,proto3,oneof"`
}

type Signal_Double 

type Signal_Double struct {
	Double float64 `protobuf:"fixed64,3,opt,name=double,proto3,oneof"`
}

type Signal_Empty 

type Signal_Empty struct {
	Empty bool `protobuf:"varint,6,opt,name=empty,proto3,oneof"`
}

type Signal_Integer 

type Signal_Integer struct {
	Integer int64 `protobuf:"varint,2,opt,name=integer,proto3,oneof"`
}

type Signals 

type Signals struct {
	Signal               []*Signal `protobuf:"bytes,1,rep,name=signal,proto3" json:"signal,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Signals) Descriptor 

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

func (*Signals) GetSignal 

func (m *Signals) GetSignal() []*Signal

func (*Signals) ProtoMessage 

func (*Signals) ProtoMessage()

func (*Signals) Reset 

func (m *Signals) Reset()

func (*Signals) String 

func (m *Signals) String() string

func (*Signals) XXX_DiscardUnknown 

func (m *Signals) XXX_DiscardUnknown()

func (*Signals) XXX_Marshal 

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

func (*Signals) XXX_Merge 

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

func (*Signals) XXX_Size 

func (m *Signals) XXX_Size() int

func (*Signals) XXX_Unmarshal 

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

type SubscriberConfig 

type SubscriberConfig struct {
	ClientId             *ClientId  `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Signals              *SignalIds `protobuf:"bytes,2,opt,name=signals,proto3" json:"signals,omitempty"`
	OnChange             bool       `protobuf:"varint,3,opt,name=onChange,proto3" json:"onChange,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SubscriberConfig) Descriptor 

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

func (*SubscriberConfig) GetClientId 

func (m *SubscriberConfig) GetClientId() *ClientId

func (*SubscriberConfig) GetOnChange 

func (m *SubscriberConfig) GetOnChange() bool

func (*SubscriberConfig) GetSignals 

func (m *SubscriberConfig) GetSignals() *SignalIds

func (*SubscriberConfig) ProtoMessage 

func (*SubscriberConfig) ProtoMessage()

func (*SubscriberConfig) Reset 

func (m *SubscriberConfig) Reset()

func (*SubscriberConfig) String 

func (m *SubscriberConfig) String() string

func (*SubscriberConfig) XXX_DiscardUnknown 

func (m *SubscriberConfig) XXX_DiscardUnknown()

func (*SubscriberConfig) XXX_Marshal 

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

func (*SubscriberConfig) XXX_Merge 

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

func (*SubscriberConfig) XXX_Size 

func (m *SubscriberConfig) XXX_Size() int

func (*SubscriberConfig) XXX_Unmarshal 

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

type SubscriberRequest 

type SubscriberRequest struct {
	ClientId             *ClientId `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	OnChange             bool      `protobuf:"varint,2,opt,name=onChange,proto3" json:"onChange,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SubscriberRequest) Descriptor 

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

func (*SubscriberRequest) GetClientId 

func (m *SubscriberRequest) GetClientId() *ClientId

func (*SubscriberRequest) GetOnChange 

func (m *SubscriberRequest) GetOnChange() bool

func (*SubscriberRequest) ProtoMessage 

func (*SubscriberRequest) ProtoMessage()

func (*SubscriberRequest) Reset 

func (m *SubscriberRequest) Reset()

func (*SubscriberRequest) String 

func (m *SubscriberRequest) String() string

func (*SubscriberRequest) XXX_DiscardUnknown 

func (m *SubscriberRequest) XXX_DiscardUnknown()

func (*SubscriberRequest) XXX_Marshal 

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

func (*SubscriberRequest) XXX_Merge 

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

func (*SubscriberRequest) XXX_Size 

func (m *SubscriberRequest) XXX_Size() int

func (*SubscriberRequest) XXX_Unmarshal 

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

type SystemServiceClient 

type SystemServiceClient interface {
	GetConfiguration(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Configuration, error)
	ListSignals(ctx context.Context, in *NameSpace, opts ...grpc.CallOption) (*Frames, error)
}

SystemServiceClient is the client API for SystemService service.

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

func NewSystemServiceClient 

func NewSystemServiceClient(cc *grpc.ClientConn) SystemServiceClient

type SystemServiceServer 

type SystemServiceServer interface {
	GetConfiguration(context.Context, *Empty) (*Configuration, error)
	ListSignals(context.Context, *NameSpace) (*Frames, error)
}

SystemServiceServer is the server API for SystemService service.

type UnimplementedDiagnosticsServiceServer 

type UnimplementedDiagnosticsServiceServer struct {
}

UnimplementedDiagnosticsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiagnosticsServiceServer) SendDiagnosticsQuery 

func (*UnimplementedDiagnosticsServiceServer) SendDiagnosticsQuery(ctx context.Context, req *DiagnosticsRequest) (*DiagnosticsResponse, error)

type UnimplementedFunctionalServiceServer 

type UnimplementedFunctionalServiceServer struct {
}

UnimplementedFunctionalServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFunctionalServiceServer) ClosePassWindow 

func (*UnimplementedFunctionalServiceServer) ClosePassWindow(ctx context.Context, req *ClientId) (*Empty, error)

func (*UnimplementedFunctionalServiceServer) OpenPassWindow 

func (*UnimplementedFunctionalServiceServer) OpenPassWindow(ctx context.Context, req *ClientId) (*Empty, error)

func (*UnimplementedFunctionalServiceServer) SetFanSpeed 

func (*UnimplementedFunctionalServiceServer) SetFanSpeed(ctx context.Context, req *SenderInfo) (*Empty, error)

func (*UnimplementedFunctionalServiceServer) SubscribeToFanSpeed 

func (*UnimplementedFunctionalServiceServer) SubscribeToFanSpeed(req *SubscriberRequest, srv FunctionalService_SubscribeToFanSpeedServer) error

type UnimplementedNetworkServiceServer 

type UnimplementedNetworkServiceServer struct {
}

UnimplementedNetworkServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServiceServer) PublishSignals 

func (*UnimplementedNetworkServiceServer) PublishSignals(ctx context.Context, req *PublisherConfig) (*Empty, error)

func (*UnimplementedNetworkServiceServer) ReadSignals 

func (*UnimplementedNetworkServiceServer) ReadSignals(ctx context.Context, req *SignalIds) (*Signals, error)

func (*UnimplementedNetworkServiceServer) SubscribeToSignals 

func (*UnimplementedNetworkServiceServer) SubscribeToSignals(req *SubscriberConfig, srv NetworkService_SubscribeToSignalsServer) error

type UnimplementedSystemServiceServer 

type UnimplementedSystemServiceServer struct {
}

UnimplementedSystemServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSystemServiceServer) GetConfiguration 

func (*UnimplementedSystemServiceServer) GetConfiguration(ctx context.Context, req *Empty) (*Configuration, error)

func (*UnimplementedSystemServiceServer) ListSignals 

func (*UnimplementedSystemServiceServer) ListSignals(ctx context.Context, req *NameSpace) (*Frames, error)

type Value 

type Value struct {
	Payload              int32    `protobuf:"varint,1,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Value) Descriptor 

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

func (*Value) GetPayload 

func (m *Value) GetPayload() int32

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) String 

func (m *Value) String() string

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

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

func (*Value) XXX_Merge 

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

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

func (m *Value) XXX_Unmarshal(b []byte) 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.