base

package
v0.0.0-...-414c0a5 Latest Latest
Warning

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

Go to latest
Published: Nov 7, 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

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) SetFanSpeed

func (*UnimplementedFunctionalServiceServer) SubscribeToFanSpeed

type UnimplementedNetworkServiceServer

type UnimplementedNetworkServiceServer struct {
}

UnimplementedNetworkServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServiceServer) PublishSignals

func (*UnimplementedNetworkServiceServer) ReadSignals

func (*UnimplementedNetworkServiceServer) SubscribeToSignals

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL