v1

package

Go to main page

Versions in this module

v1

v1.13.0

Aug 18, 2024

Changes in this version

type DeviceType

+ const DeviceTypeMQTTGPIO

+ const DeviceTypeMQTTServo

v1.12.1

Aug 10, 2024

Changes in this version

+ const ServiceTypePrometheusProvider

type DeviceType

+ const DeviceTypeMQTT

type LocalWorkerInfo

+ SshPort int32

+ func (m *LocalWorkerInfo) GetSshPort() int32

+ type ServiceBroadcaster struct

+ func NewServiceBroadcaster(log zerolog.Logger, hostMask, serviceType string, info ServiceInfo) *ServiceBroadcaster

+ func (sb *ServiceBroadcaster) Run(ctx context.Context) error

type ServiceInfo

+ ProviderName string

+ func (m *ServiceInfo) GetProviderName() string

v1.12.0

Apr 21, 2024

Changes in this version

type LocalWorkerInfo

+ SupportsSetDeviceDiscoveryRequest bool

+ func (m *LocalWorkerInfo) GetSupportsSetDeviceDiscoveryRequest() bool

type LocalWorkerServiceClient

+ SetDeviceDiscoveryRequest func(ctx context.Context, in *DeviceDiscovery, opts ...grpc.CallOption) (*Empty, error)

type LocalWorkerServiceServer

+ SetDeviceDiscoveryRequest func(context.Context, *DeviceDiscovery) (*Empty, error)

type UnimplementedLocalWorkerServiceServer

+ func (*UnimplementedLocalWorkerServiceServer) SetDeviceDiscoveryRequest(ctx context.Context, req *DeviceDiscovery) (*Empty, error)

v1.11.0

Apr 21, 2024

Changes in this version

type LocalWorkerInfo

+ SupportsReset bool

+ SupportsSetLocRequest bool

+ SupportsSetOutputRequest bool

+ SupportsSetPowerRequest bool

+ SupportsSetSwitchRequest bool

+ func (m *LocalWorkerInfo) GetSupportsReset() bool

+ func (m *LocalWorkerInfo) GetSupportsSetLocRequest() bool

+ func (m *LocalWorkerInfo) GetSupportsSetOutputRequest() bool

+ func (m *LocalWorkerInfo) GetSupportsSetPowerRequest() bool

+ func (m *LocalWorkerInfo) GetSupportsSetSwitchRequest() bool

type LocalWorkerServiceClient

+ SetLocRequest func(ctx context.Context, in *Loc, opts ...grpc.CallOption) (*Empty, error)

+ SetOutputRequest func(ctx context.Context, in *Output, opts ...grpc.CallOption) (*Empty, error)

+ SetPowerRequest func(ctx context.Context, in *PowerState, opts ...grpc.CallOption) (*Empty, error)

+ SetSwitchRequest func(ctx context.Context, in *Switch, opts ...grpc.CallOption) (*Empty, error)

type LocalWorkerServiceServer

+ SetLocRequest func(context.Context, *Loc) (*Empty, error)

+ SetOutputRequest func(context.Context, *Output) (*Empty, error)

+ SetPowerRequest func(context.Context, *PowerState) (*Empty, error)

+ SetSwitchRequest func(context.Context, *Switch) (*Empty, error)

type UnimplementedLocalWorkerServiceServer

+ func (*UnimplementedLocalWorkerServiceServer) SetLocRequest(ctx context.Context, req *Loc) (*Empty, error)

+ func (*UnimplementedLocalWorkerServiceServer) SetOutputRequest(ctx context.Context, req *Output) (*Empty, error)

+ func (*UnimplementedLocalWorkerServiceServer) SetPowerRequest(ctx context.Context, req *PowerState) (*Empty, error)

+ func (*UnimplementedLocalWorkerServiceServer) SetSwitchRequest(ctx context.Context, req *Switch) (*Empty, error)

v1.10.0

Apr 21, 2024

Changes in this version

+ func RegisterLocalWorkerServiceServer(s *grpc.Server, srv LocalWorkerServiceServer)

type LocalWorkerInfo

+ LocalWorkerServicePort int32

+ LocalWorkerServiceSecure bool

+ func (m *LocalWorkerInfo) GetLocalWorkerServicePort() int32

+ func (m *LocalWorkerInfo) GetLocalWorkerServiceSecure() bool

+ type LocalWorkerServiceClient interface

+ Reset func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ func NewLocalWorkerServiceClient(cc *grpc.ClientConn) LocalWorkerServiceClient

+ type LocalWorkerServiceServer interface

+ Reset func(context.Context, *Empty) (*Empty, error)

+ type UnimplementedLocalWorkerServiceServer struct

+ func (*UnimplementedLocalWorkerServiceServer) Reset(ctx context.Context, req *Empty) (*Empty, error)

v1.9.0

Apr 21, 2024

v1.8.0

Apr 20, 2024

Changes in this version

type LocalWorkerConfig

+ Reset_ bool

+ func (m *LocalWorkerConfig) GetReset_() bool

v1.7.2

Jan 7, 2024

v1.7.1

Jan 6, 2024

v1.7.0

Jan 6, 2024

v1.6.1

Dec 12, 2023

Changes in this version

type Object

+ func (o Object) GetBoolConfig(key ObjectConfigKey) bool

+ func (o Object) GetIntConfig(key ObjectConfigKey) int

+ func (o Object) GetStringConfig(key ObjectConfigKey) string

v1.6.0

Dec 12, 2023

Changes in this version

type Object

+ Configuration map[ObjectConfigKey]string

+ func (m *Object) GetConfiguration() map[ObjectConfigKey]string

+ type ObjectConfigKey string

+ const ObjectConfigKeyDebug

+ const ObjectConfigKeyMagneticAlwaysEnabled

+ const ObjectConfigKeyMagneticOffInvert

+ const ObjectConfigKeyMagneticStraightInvert

+ func AllObjectConfigKeys() []ObjectConfigKey

+ func (key ObjectConfigKey) DefaultValue() string

+ func (key ObjectConfigKey) ValidateValue(value string) error

v1.5.0

Nov 19, 2023

Changes in this version

type ConnectionName

+ const ConnectionNameMagneticOffA

+ const ConnectionNameMagneticOffB

+ const ConnectionNameMagneticStraightA

+ const ConnectionNameMagneticStraightB

type DeviceType

+ const DeviceTypeBinkyCarSensor

type ObjectType

+ const ObjectTypeMagneticSwitch

v1.4.2

Nov 18, 2023

Changes in this version

type SwitchState

+ IsUsed bool

+ func (m *SwitchState) GetIsUsed() bool

v1.4.1

Feb 10, 2023

v1.4.0

Feb 5, 2023

Changes in this version

type LocalWorkerInfo

+ MetricsPort int32

+ MetricsSecure bool

+ func (m *LocalWorkerInfo) GetMetricsPort() int32

+ func (m *LocalWorkerInfo) GetMetricsSecure() bool

v1.3.6

Feb 4, 2023

v1.3.5

Feb 4, 2023

v1.3.4

Jan 8, 2023

v1.3.3

Dec 30, 2022

Changes in this version

type LocalWorkerInfo

+ UnconfiguredDeviceIds []string

+ UnconfiguredObjectIds []string

+ func (m *LocalWorkerInfo) GetUnconfiguredDeviceIds() []string

+ func (m *LocalWorkerInfo) GetUnconfiguredObjectIds() []string

v1.3.2

Dec 30, 2022

Changes in this version

type LocalWorkerInfo

+ ConfiguredDeviceIds []string

+ ConfiguredObjectIds []string

+ func (m *LocalWorkerInfo) GetConfiguredDeviceIds() []string

+ func (m *LocalWorkerInfo) GetConfiguredObjectIds() []string

v1.3.1

Oct 23, 2022

v1.3.0

Oct 23, 2022

Changes in this version

type ConfigKey

+ const ConfigKeyThreshold

v1.2.0

Oct 23, 2022

v1.1.1

Oct 23, 2022

Changes in this version

type ConfigKey

+ const ConfigKeyDebug

v1.1.0

Oct 22, 2022

Changes in this version

type ConfigKey

+ const ConfigKeyAnalogSensorThreshold

type DeviceType

+ const DeviceTypeADS1115

type ObjectType

+ const ObjectTypeAnalogSensor

v1.0.1

Jul 6, 2022

v1.0.0

Jul 6, 2022

Changes in this version

+ var ErrIntOverflowNetwork = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthNetwork = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupNetwork = fmt.Errorf("proto: unexpected end of group")

type Clock

+ Unixtime int64

+ func (m *Clock) GetUnixtime() int64

type Connection

+ func (s *Connection) Clone() *Connection

+ func (s *Connection) HashTo(h hash.Hash)

type Device

+ func (s *Device) Clone() *Device

+ func (s *Device) HashTo(h hash.Hash)

+ type DeviceDiscovery struct

+ Actual *DiscoverResult

+ Id string

+ Request *DiscoverRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeviceDiscovery) Descriptor() ([]byte, []int)

+ func (*DeviceDiscovery) ProtoMessage()

+ func (m *DeviceDiscovery) GetActual() *DiscoverResult

+ func (m *DeviceDiscovery) GetId() string

+ func (m *DeviceDiscovery) GetRequest() *DiscoverRequest

+ func (m *DeviceDiscovery) Marshal() (dAtA []byte, err error)

+ func (m *DeviceDiscovery) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeviceDiscovery) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeviceDiscovery) Reset()

+ func (m *DeviceDiscovery) Size() (n int)

+ func (m *DeviceDiscovery) String() string

+ func (m *DeviceDiscovery) Unmarshal(dAtA []byte) error

+ func (m *DeviceDiscovery) XXX_DiscardUnknown()

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

+ func (m *DeviceDiscovery) XXX_Merge(src proto.Message)

+ func (m *DeviceDiscovery) XXX_Size() int

+ func (m *DeviceDiscovery) XXX_Unmarshal(b []byte) error

+ func (s *DeviceDiscovery) Clone() *DeviceDiscovery

type DevicePin

+ func (s *DevicePin) Clone() *DevicePin

+ func (s *DevicePin) HashTo(h hash.Hash)

type DiscoverRequest

+ RequestId int32

+ func (m *DiscoverRequest) GetRequestId() int32

+ func (s *DiscoverRequest) Clone() *DiscoverRequest

type DiscoverResult

+ func (s *DiscoverResult) Clone() *DiscoverResult

+ type LocalWorker struct

+ Actual *LocalWorkerInfo

+ Id string

+ Request *LocalWorkerConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LocalWorker) Descriptor() ([]byte, []int)

+ func (*LocalWorker) ProtoMessage()

+ func (m *LocalWorker) GetActual() *LocalWorkerInfo

+ func (m *LocalWorker) GetId() string

+ func (m *LocalWorker) GetRequest() *LocalWorkerConfig

+ func (m *LocalWorker) Marshal() (dAtA []byte, err error)

+ func (m *LocalWorker) MarshalTo(dAtA []byte) (int, error)

+ func (m *LocalWorker) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LocalWorker) Reset()

+ func (m *LocalWorker) Size() (n int)

+ func (m *LocalWorker) String() string

+ func (m *LocalWorker) Unmarshal(dAtA []byte) error

+ func (m *LocalWorker) XXX_DiscardUnknown()

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

+ func (m *LocalWorker) XXX_Merge(src proto.Message)

+ func (m *LocalWorker) XXX_Size() int

+ func (m *LocalWorker) XXX_Unmarshal(b []byte) error

+ func (s *LocalWorker) Clone() *LocalWorker

type LocalWorkerConfig

+ Hash string

+ func (m *LocalWorkerConfig) GetHash() string

+ func (s *LocalWorkerConfig) Clone() *LocalWorkerConfig

+ func (s *LocalWorkerConfig) HashTo(h hash.Hash)

+ func (s *LocalWorkerConfig) Sha1() string

type LocalWorkerInfo

+ ConfigHash string

+ func (m *LocalWorkerInfo) GetConfigHash() string

+ func (s *LocalWorkerInfo) Clone() *LocalWorkerInfo

type NetworkControlServiceClient

+ SetClockActual func(ctx context.Context, in *Clock, opts ...grpc.CallOption) (*Empty, error)

+ SetDeviceDiscoveryActual func(ctx context.Context, in *DeviceDiscovery, opts ...grpc.CallOption) (*Empty, error)

+ SetDeviceDiscoveryRequest func(ctx context.Context, in *DeviceDiscovery, opts ...grpc.CallOption) (*Empty, error)

+ SetLocActual func(ctx context.Context, in *Loc, opts ...grpc.CallOption) (*Empty, error)

+ SetLocRequest func(ctx context.Context, in *Loc, opts ...grpc.CallOption) (*Empty, error)

+ SetLocalWorkerActual func(ctx context.Context, in *LocalWorker, opts ...grpc.CallOption) (*Empty, error)

+ SetLocalWorkerRequest func(ctx context.Context, in *LocalWorker, opts ...grpc.CallOption) (*Empty, error)

+ SetOutputActual func(ctx context.Context, in *Output, opts ...grpc.CallOption) (*Empty, error)

+ SetOutputRequest func(ctx context.Context, in *Output, opts ...grpc.CallOption) (*Empty, error)

+ SetPowerActual func(ctx context.Context, in *PowerState, opts ...grpc.CallOption) (*Empty, error)

+ SetPowerRequest func(ctx context.Context, in *PowerState, opts ...grpc.CallOption) (*Empty, error)

+ SetSensorActual func(ctx context.Context, in *Sensor, opts ...grpc.CallOption) (*Empty, error)

+ SetSwitchActual func(ctx context.Context, in *Switch, opts ...grpc.CallOption) (*Empty, error)

+ SetSwitchRequest func(ctx context.Context, in *Switch, opts ...grpc.CallOption) (*Empty, error)

+ WatchClock func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchClockClient, error)

+ WatchDeviceDiscoveries func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchDeviceDiscoveriesClient, error)

+ WatchLocalWorkers func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchLocalWorkersClient, error)

+ WatchLocs func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchLocsClient, error)

+ WatchOutputs func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchOutputsClient, error)

+ WatchPower func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchPowerClient, error)

+ WatchSensors func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchSensorsClient, error)

+ WatchSwitches func(ctx context.Context, in *WatchOptions, opts ...grpc.CallOption) (NetworkControlService_WatchSwitchesClient, error)

type NetworkControlServiceServer

+ SetClockActual func(context.Context, *Clock) (*Empty, error)

+ SetDeviceDiscoveryActual func(context.Context, *DeviceDiscovery) (*Empty, error)

+ SetDeviceDiscoveryRequest func(context.Context, *DeviceDiscovery) (*Empty, error)

+ SetLocActual func(context.Context, *Loc) (*Empty, error)

+ SetLocRequest func(context.Context, *Loc) (*Empty, error)

+ SetLocalWorkerActual func(context.Context, *LocalWorker) (*Empty, error)

+ SetLocalWorkerRequest func(context.Context, *LocalWorker) (*Empty, error)

+ SetOutputActual func(context.Context, *Output) (*Empty, error)

+ SetOutputRequest func(context.Context, *Output) (*Empty, error)

+ SetPowerActual func(context.Context, *PowerState) (*Empty, error)

+ SetPowerRequest func(context.Context, *PowerState) (*Empty, error)

+ SetSensorActual func(context.Context, *Sensor) (*Empty, error)

+ SetSwitchActual func(context.Context, *Switch) (*Empty, error)

+ SetSwitchRequest func(context.Context, *Switch) (*Empty, error)

+ WatchClock func(*WatchOptions, NetworkControlService_WatchClockServer) error

+ WatchDeviceDiscoveries func(*WatchOptions, NetworkControlService_WatchDeviceDiscoveriesServer) error

+ WatchLocalWorkers func(*WatchOptions, NetworkControlService_WatchLocalWorkersServer) error

+ WatchLocs func(*WatchOptions, NetworkControlService_WatchLocsServer) error

+ WatchOutputs func(*WatchOptions, NetworkControlService_WatchOutputsServer) error

+ WatchPower func(*WatchOptions, NetworkControlService_WatchPowerServer) error

+ WatchSensors func(*WatchOptions, NetworkControlService_WatchSensorsServer) error

+ WatchSwitches func(*WatchOptions, NetworkControlService_WatchSwitchesServer) error

+ type NetworkControlService_WatchClockClient interface

+ Recv func() (*Clock, error)

+ type NetworkControlService_WatchClockServer interface

+ Send func(*Clock) error

+ type NetworkControlService_WatchDeviceDiscoveriesClient interface

+ Recv func() (*DeviceDiscovery, error)

+ type NetworkControlService_WatchDeviceDiscoveriesServer interface

+ Send func(*DeviceDiscovery) error

+ type NetworkControlService_WatchLocalWorkersClient interface

+ Recv func() (*LocalWorker, error)

+ type NetworkControlService_WatchLocalWorkersServer interface

+ Send func(*LocalWorker) error

+ type NetworkControlService_WatchLocsClient interface

+ Recv func() (*Loc, error)

+ type NetworkControlService_WatchLocsServer interface

+ Send func(*Loc) error

+ type NetworkControlService_WatchOutputsClient interface

+ Recv func() (*Output, error)

+ type NetworkControlService_WatchOutputsServer interface

+ Send func(*Output) error

+ type NetworkControlService_WatchPowerClient interface

+ Recv func() (*Power, error)

+ type NetworkControlService_WatchPowerServer interface

+ Send func(*Power) error

+ type NetworkControlService_WatchSensorsClient interface

+ Recv func() (*Sensor, error)

+ type NetworkControlService_WatchSensorsServer interface

+ Send func(*Sensor) error

+ type NetworkControlService_WatchSwitchesClient interface

+ Recv func() (*Switch, error)

+ type NetworkControlService_WatchSwitchesServer interface

+ Send func(*Switch) error

type Object

+ func (s *Object) Clone() *Object

+ func (s *Object) HashTo(h hash.Hash)

type UnimplementedNetworkControlServiceServer

+ func (*UnimplementedNetworkControlServiceServer) SetClockActual(ctx context.Context, req *Clock) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetDeviceDiscoveryActual(ctx context.Context, req *DeviceDiscovery) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetDeviceDiscoveryRequest(ctx context.Context, req *DeviceDiscovery) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetLocActual(ctx context.Context, req *Loc) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetLocRequest(ctx context.Context, req *Loc) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetLocalWorkerActual(ctx context.Context, req *LocalWorker) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetLocalWorkerRequest(ctx context.Context, req *LocalWorker) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetOutputActual(ctx context.Context, req *Output) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetOutputRequest(ctx context.Context, req *Output) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetPowerActual(ctx context.Context, req *PowerState) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetPowerRequest(ctx context.Context, req *PowerState) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetSensorActual(ctx context.Context, req *Sensor) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetSwitchActual(ctx context.Context, req *Switch) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) SetSwitchRequest(ctx context.Context, req *Switch) (*Empty, error)

+ func (*UnimplementedNetworkControlServiceServer) WatchClock(req *WatchOptions, srv NetworkControlService_WatchClockServer) error

+ func (*UnimplementedNetworkControlServiceServer) WatchDeviceDiscoveries(req *WatchOptions, srv NetworkControlService_WatchDeviceDiscoveriesServer) error

+ func (*UnimplementedNetworkControlServiceServer) WatchLocalWorkers(req *WatchOptions, srv NetworkControlService_WatchLocalWorkersServer) error

+ func (*UnimplementedNetworkControlServiceServer) WatchLocs(req *WatchOptions, srv NetworkControlService_WatchLocsServer) error

+ func (*UnimplementedNetworkControlServiceServer) WatchOutputs(req *WatchOptions, srv NetworkControlService_WatchOutputsServer) error

+ func (*UnimplementedNetworkControlServiceServer) WatchPower(req *WatchOptions, srv NetworkControlService_WatchPowerServer) error

+ func (*UnimplementedNetworkControlServiceServer) WatchSensors(req *WatchOptions, srv NetworkControlService_WatchSensorsServer) error

+ func (*UnimplementedNetworkControlServiceServer) WatchSwitches(req *WatchOptions, srv NetworkControlService_WatchSwitchesServer) error

+ type WatchOptions struct

+ ModuleId string

+ WatchActualChanges bool

+ WatchRequestChanges bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WatchOptions) Descriptor() ([]byte, []int)

+ func (*WatchOptions) ProtoMessage()

+ func (m *WatchOptions) GetModuleId() string

+ func (m *WatchOptions) GetWatchActualChanges() bool

+ func (m *WatchOptions) GetWatchRequestChanges() bool

+ func (m *WatchOptions) Marshal() (dAtA []byte, err error)

+ func (m *WatchOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *WatchOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchOptions) Reset()

+ func (m *WatchOptions) Size() (n int)

+ func (m *WatchOptions) String() string

+ func (m *WatchOptions) Unmarshal(dAtA []byte) error

+ func (m *WatchOptions) XXX_DiscardUnknown()

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

+ func (m *WatchOptions) XXX_Merge(src proto.Message)

+ func (m *WatchOptions) XXX_Size() int

+ func (m *WatchOptions) XXX_Unmarshal(b []byte) error

v0

v0.14.5

Feb 28, 2022

v0.14.4

Feb 28, 2022

v0.14.3

Feb 28, 2022

v0.14.2

Feb 28, 2022

v0.14.1

Feb 27, 2022

v0.14.0

Feb 27, 2022

v0.13.0

Feb 27, 2022

Changes in this version

type LocalWorkerConfig

+ Unixtime int64

+ func (m *LocalWorkerConfig) GetUnixtime() int64

v0.12.3

Feb 20, 2022

v0.12.2

Feb 19, 2022

v0.12.1

Feb 19, 2022

v0.12.0

Feb 19, 2022

Changes in this version

+ const ServiceTypeLokiProvider

v0.11.1

Feb 19, 2022

Changes in this version

type Connection

+ func (s *Connection) Equal(o *Connection) bool

type Device

+ func (s *Device) Equal(o *Device) bool

type DevicePin

+ func (s *DevicePin) Equal(o *DevicePin) bool

type LocalWorkerConfig

+ func (s *LocalWorkerConfig) Equal(o *LocalWorkerConfig) bool

type Object

+ func (s *Object) Equal(o *Object) bool

v0.11.0

Nov 2, 2021

Changes in this version

type DeviceType

+ const DeviceTypePCF8574

v0.10.1

Oct 17, 2021

Changes in this version

type ObjectAddress

+ func (addr ObjectAddress) IsGlobal() bool

v0.10.0

Oct 16, 2021

Changes in this version

+ const GlobalModuleID

v0.9.8

Oct 16, 2021

Changes in this version

+ type TrackInverterState int32

+ const TrackInverterStateDefault

+ const TrackInverterStateNotConnected

+ const TrackInverterStateReverse

v0.9.7

Oct 11, 2021

v0.9.6

Sep 12, 2021

Changes in this version

type OutputRequestsOptions

+ ModuleId string

+ func (m *OutputRequestsOptions) GetModuleId() string

type SwitchRequestsOptions

+ ModuleId string

+ func (m *SwitchRequestsOptions) GetModuleId() string

v0.9.5

Jul 31, 2021

v0.9.4

Jul 31, 2021

Changes in this version

type ConfigKey

+ const ConfigKeyInvert

+ const ConfigKeyPulse

v0.9.3

Jul 31, 2021

v0.9.2

Jul 9, 2021

Changes in this version

type ConnectionName

+ const ConnectionNameRelayOutAInA

+ const ConnectionNameRelayOutAInB

+ const ConnectionNameRelayOutBInA

+ const ConnectionNameRelayOutBInB

type ObjectType

+ const ObjectTypeTrackInverter

v0.9.1

May 23, 2021

v0.9.0

May 23, 2021

v0.8.1

May 22, 2021

Changes in this version

type ConnectionName

+ func (ot ConnectionName) ExpectedConfigurations() ([]ConfigKey, []ConfigKey)

v0.8.0

May 22, 2021

v0.7.0

May 22, 2021

v0.6.2

May 22, 2021

Changes in this version

+ type ConfigKey string

+ const ConfigKeyServoOff

+ const ConfigKeyServoStep

+ const ConfigKeyServoStraight

+ func AllConfigKeys() []ConfigKey

+ func (key ConfigKey) DefaultValue() string

+ func (key ConfigKey) ValidateValue(value string) error

type ObjectType

+ func (ot ObjectType) ExpectedConfigurations() ([]ConfigKey, []ConfigKey)

v0.6.1

Mar 27, 2021

Changes in this version

type ConnectionName

+ func (name ConnectionName) ExpectedPins() int

v0.6.0

Mar 7, 2021

Changes in this version

type DiscoverResult

+ Id string

+ func (m *DiscoverResult) GetId() string

v0.5.0

Mar 7, 2021

Changes in this version

+ type DiscoverResult struct

+ Addresses []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DiscoverResult) Descriptor() ([]byte, []int)

+ func (*DiscoverResult) ProtoMessage()

+ func (m *DiscoverResult) GetAddresses() []string

+ func (m *DiscoverResult) Marshal() (dAtA []byte, err error)

+ func (m *DiscoverResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *DiscoverResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DiscoverResult) Reset()

+ func (m *DiscoverResult) Size() (n int)

+ func (m *DiscoverResult) String() string

+ func (m *DiscoverResult) Unmarshal(dAtA []byte) error

+ func (m *DiscoverResult) XXX_DiscardUnknown()

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

+ func (m *DiscoverResult) XXX_Merge(src proto.Message)

+ func (m *DiscoverResult) XXX_Size() int

+ func (m *DiscoverResult) XXX_Unmarshal(b []byte) error

type LocalWorkerControlServiceClient

+ SetDiscoverResult func(ctx context.Context, in *DiscoverResult, opts ...grpc.CallOption) (*Empty, error)

type LocalWorkerControlServiceServer

+ SetDiscoverResult func(context.Context, *DiscoverResult) (*Empty, error)

type UnimplementedLocalWorkerControlServiceServer

+ func (*UnimplementedLocalWorkerControlServiceServer) SetDiscoverResult(ctx context.Context, req *DiscoverResult) (*Empty, error)

v0.4.1

Mar 7, 2021

Changes in this version

type DiscoverRequest

+ Id string

+ func (m *DiscoverRequest) GetId() string

v0.4.0

Mar 7, 2021

Changes in this version

+ var ErrIntOverflowLocalworker = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthLocalworker = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupLocalworker = fmt.Errorf("proto: unexpected end of group")

+ type DiscoverRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DiscoverRequest) Descriptor() ([]byte, []int)

+ func (*DiscoverRequest) ProtoMessage()

+ func (m *DiscoverRequest) Marshal() (dAtA []byte, err error)

+ func (m *DiscoverRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DiscoverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DiscoverRequest) Reset()

+ func (m *DiscoverRequest) Size() (n int)

+ func (m *DiscoverRequest) String() string

+ func (m *DiscoverRequest) Unmarshal(dAtA []byte) error

+ func (m *DiscoverRequest) XXX_DiscardUnknown()

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

+ func (m *DiscoverRequest) XXX_Merge(src proto.Message)

+ func (m *DiscoverRequest) XXX_Size() int

+ func (m *DiscoverRequest) XXX_Unmarshal(b []byte) error

+ type DiscoverResponse struct

+ Addresses []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DiscoverResponse) Descriptor() ([]byte, []int)

+ func (*DiscoverResponse) ProtoMessage()

+ func (m *DiscoverResponse) GetAddresses() []string

+ func (m *DiscoverResponse) Marshal() (dAtA []byte, err error)

+ func (m *DiscoverResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DiscoverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DiscoverResponse) Reset()

+ func (m *DiscoverResponse) Size() (n int)

+ func (m *DiscoverResponse) String() string

+ func (m *DiscoverResponse) Unmarshal(dAtA []byte) error

+ func (m *DiscoverResponse) XXX_DiscardUnknown()

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

+ func (m *DiscoverResponse) XXX_Merge(src proto.Message)

+ func (m *DiscoverResponse) XXX_Size() int

+ func (m *DiscoverResponse) XXX_Unmarshal(b []byte) error

type LocalWorkerControlServiceClient

+ GetDiscoverRequests func(ctx context.Context, opts ...grpc.CallOption) (LocalWorkerControlService_GetDiscoverRequestsClient, error)

type LocalWorkerControlServiceServer

+ GetDiscoverRequests func(LocalWorkerControlService_GetDiscoverRequestsServer) error

+ type LocalWorkerControlService_GetDiscoverRequestsClient interface

+ Recv func() (*DiscoverResponse, error)

+ Send func(*DiscoverRequest) error

+ type LocalWorkerControlService_GetDiscoverRequestsServer interface

+ Recv func() (*DiscoverRequest, error)

+ Send func(*DiscoverResponse) error

type UnimplementedLocalWorkerControlServiceServer

+ func (*UnimplementedLocalWorkerControlServiceServer) GetDiscoverRequests(srv LocalWorkerControlService_GetDiscoverRequestsServer) error

v0.3.0

Mar 7, 2021

Changes in this version

type LogEntry

+ Level LogLevel

+ func (m *LogEntry) GetLevel() LogLevel

v0.2.4

Mar 6, 2021

Changes in this version

type ObjectType

+ func (ot ObjectType) ExpectedConnections() ([]ConnectionName, []ConnectionName)

v0.2.3

Mar 6, 2021

Changes in this version

type ObjectType

+ func (ot ObjectType) ExceptedConnections() []ConnectionName

v0.2.2

Mar 6, 2021

Changes in this version

+ func GetServiceInfoHost(ctx context.Context) (string, bool)

+ func WithServiceInfoHost(ctx context.Context, host string) context.Context

type CommandStationServiceClient

+ Locs func(ctx context.Context, opts ...grpc.CallOption) (CommandStationService_LocsClient, error)

+ Power func(ctx context.Context, opts ...grpc.CallOption) (CommandStationService_PowerClient, error)

type CommandStationServiceServer

+ Locs func(CommandStationService_LocsServer) error

+ Power func(CommandStationService_PowerServer) error

+ type CommandStationService_LocsClient interface

+ Recv func() (*Loc, error)

+ Send func(*Loc) error

+ type CommandStationService_LocsServer interface

+ Recv func() (*Loc, error)

+ Send func(*Loc) error

+ type CommandStationService_PowerClient interface

+ Recv func() (*Power, error)

+ Send func(*PowerState) error

+ type CommandStationService_PowerServer interface

+ Recv func() (*PowerState, error)

+ Send func(*Power) error

type ConnectionName

+ func AllConnectionNames() []ConnectionName

type DeviceType

+ func AllDeviceTypes() []DeviceType

type ObjectType

+ func AllObjectTypes() []ObjectType

type UnimplementedCommandStationServiceServer

+ func (*UnimplementedCommandStationServiceServer) Locs(srv CommandStationService_LocsServer) error

+ func (*UnimplementedCommandStationServiceServer) Power(srv CommandStationService_PowerServer) error

v0.1.0

Jun 28, 2020

Changes in this version

+ const ServiceTypeCommandStation

+ const ServiceTypeLocalWorkerConfig

+ const ServiceTypeLocalWorkerControl

+ const ServiceTypeLogProvider

+ const ServiceTypeNetworkControl

+ var Cause = func(err error) error

+ var ErrIntOverflowDiscovery = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowLogprovider = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDiscovery = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthLogprovider = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupDiscovery = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupLogprovider = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")

+ var LocDirection_name = map[int32]string

+ var LocDirection_value = map[string]int32

+ var LogLevel_name = map[int32]string

+ var LogLevel_value = map[string]int32

+ var SwitchDirection_name = map[int32]string

+ var SwitchDirection_value = map[string]int32

+ var TimePeriod_name = map[int32]string

+ var TimePeriod_value = map[string]int32

+ func AlreadyExists(msg string, args ...interface{}) error

+ func Canceled(msg string, args ...interface{}) error

+ func CreateHostID() (string, error)

+ func DeadlineExceeded(msg string, args ...interface{}) error

+ func InvalidArgument(msg string, args ...interface{}) error

+ func IsAlreadyExists(err error) bool

+ func IsCanceled(err error) bool

+ func IsDeadlineExceeded(err error) bool

+ func IsInvalidArgument(err error) bool

+ func IsNotFound(err error) bool

+ func IsPermissionDenied(err error) bool

+ func IsPreconditionFailed(err error) bool

+ func IsUnauthenticated(err error) bool

+ func IsUnknown(err error) bool

+ func NotFound(msg string, args ...interface{}) error

+ func PermissionDenied(msg string, args ...interface{}) error

+ func PreconditionFailed(msg string, args ...interface{}) error

+ func RegisterCommandStationServiceServer(s *grpc.Server, srv CommandStationServiceServer)

+ func RegisterLocalWorkerConfigServiceServer(s *grpc.Server, srv LocalWorkerConfigServiceServer)

+ func RegisterLocalWorkerControlServiceServer(s *grpc.Server, srv LocalWorkerControlServiceServer)

+ func RegisterLogProviderServiceServer(s *grpc.Server, srv LogProviderServiceServer)

+ func RegisterNetworkControlServiceServer(s *grpc.Server, srv NetworkControlServiceServer)

+ func RegisterServiceEntry(ctx context.Context, serviceType string, info ServiceInfo) error

+ func SplitAddress(input ObjectAddress) (module, local string, err error)

+ func Unauthenticated(msg string, args ...interface{}) error

+ func Unknown(msg string, args ...interface{}) error

+ type CauseFunc = func(error) error

+ type Clock struct

+ Hours int32

+ Minutes int32

+ Period TimePeriod

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Clock) Descriptor() ([]byte, []int)

+ func (*Clock) ProtoMessage()

+ func (m *Clock) GetHours() int32

+ func (m *Clock) GetMinutes() int32

+ func (m *Clock) GetPeriod() TimePeriod

+ func (m *Clock) Marshal() (dAtA []byte, err error)

+ func (m *Clock) MarshalTo(dAtA []byte) (int, error)

+ func (m *Clock) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Clock) Reset()

+ func (m *Clock) Size() (n int)

+ func (m *Clock) String() string

+ func (m *Clock) Unmarshal(dAtA []byte) error

+ func (m *Clock) XXX_DiscardUnknown()

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

+ func (m *Clock) XXX_Merge(src proto.Message)

+ func (m *Clock) XXX_Size() int

+ func (m *Clock) XXX_Unmarshal(b []byte) error

+ func (s *Clock) Clone() *Clock

+ func (s *Clock) Equal(o *Clock) bool

+ type CommandStationInfo struct

+ Description string

+ Id string

+ Uptime int64

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CommandStationInfo) Descriptor() ([]byte, []int)

+ func (*CommandStationInfo) ProtoMessage()

+ func (m *CommandStationInfo) GetDescription() string

+ func (m *CommandStationInfo) GetId() string

+ func (m *CommandStationInfo) GetUptime() int64

+ func (m *CommandStationInfo) GetVersion() string

+ func (m *CommandStationInfo) Marshal() (dAtA []byte, err error)

+ func (m *CommandStationInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *CommandStationInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CommandStationInfo) Reset()

+ func (m *CommandStationInfo) Size() (n int)

+ func (m *CommandStationInfo) String() string

+ func (m *CommandStationInfo) Unmarshal(dAtA []byte) error

+ func (m *CommandStationInfo) XXX_DiscardUnknown()

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

+ func (m *CommandStationInfo) XXX_Merge(src proto.Message)

+ func (m *CommandStationInfo) XXX_Size() int

+ func (m *CommandStationInfo) XXX_Unmarshal(b []byte) error

+ type CommandStationServiceClient interface

+ GetInfo func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*CommandStationInfo, error)

+ GetLocActuals func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (CommandStationService_GetLocActualsClient, error)

+ GetPowerActuals func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (CommandStationService_GetPowerActualsClient, error)

+ SetLoc func(ctx context.Context, in *Loc, opts ...grpc.CallOption) (*Empty, error)

+ SetPower func(ctx context.Context, in *PowerState, opts ...grpc.CallOption) (*Empty, error)

+ func NewCommandStationServiceClient(cc *grpc.ClientConn) CommandStationServiceClient

+ type CommandStationServiceServer interface

+ GetInfo func(context.Context, *Empty) (*CommandStationInfo, error)

+ GetLocActuals func(*Empty, CommandStationService_GetLocActualsServer) error

+ GetPowerActuals func(*Empty, CommandStationService_GetPowerActualsServer) error

+ SetLoc func(context.Context, *Loc) (*Empty, error)

+ SetPower func(context.Context, *PowerState) (*Empty, error)

+ type CommandStationService_GetLocActualsClient interface

+ Recv func() (*Loc, error)

+ type CommandStationService_GetLocActualsServer interface

+ Send func(*Loc) error

+ type CommandStationService_GetPowerActualsClient interface

+ Recv func() (*PowerState, error)

+ type CommandStationService_GetPowerActualsServer interface

+ Send func(*PowerState) error

+ type Connection struct

+ Configuration map[string]string

+ Key ConnectionName

+ Pins []*DevicePin

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Connection) Descriptor() ([]byte, []int)

+ func (*Connection) ProtoMessage()

+ func (c Connection) GetBoolConfig(key string, defValue bool) bool

+ func (c Connection) GetIntConfig(key string, defValue int) int

+ func (c Connection) GetStringConfig(key string, defValue string) string

+ func (m *Connection) GetConfiguration() map[string]string

+ func (m *Connection) GetPins() []*DevicePin

+ func (m *Connection) Marshal() (dAtA []byte, err error)

+ func (m *Connection) MarshalTo(dAtA []byte) (int, error)

+ func (m *Connection) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Connection) Reset()

+ func (m *Connection) Size() (n int)

+ func (m *Connection) String() string

+ func (m *Connection) Unmarshal(dAtA []byte) error

+ func (m *Connection) XXX_DiscardUnknown()

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

+ func (m *Connection) XXX_Merge(src proto.Message)

+ func (m *Connection) XXX_Size() int

+ func (m *Connection) XXX_Unmarshal(b []byte) error

+ func (s *Connection) GetKey() ConnectionName

+ type ConnectionName string

+ const ConnectionNameOffRelay

+ const ConnectionNameOutput

+ const ConnectionNamePhaseOffRelay

+ const ConnectionNamePhaseStraightRelay

+ const ConnectionNameSensor

+ const ConnectionNameServo

+ const ConnectionNameStraightRelay

+ type Device struct

+ Address string

+ Id DeviceID

+ Type DeviceType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Device) Descriptor() ([]byte, []int)

+ func (*Device) ProtoMessage()

+ func (d Device) Validate() error

+ func (m *Device) GetAddress() string

+ func (m *Device) Marshal() (dAtA []byte, err error)

+ func (m *Device) MarshalTo(dAtA []byte) (int, error)

+ func (m *Device) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Device) Reset()

+ func (m *Device) Size() (n int)

+ func (m *Device) String() string

+ func (m *Device) Unmarshal(dAtA []byte) error

+ func (m *Device) XXX_DiscardUnknown()

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

+ func (m *Device) XXX_Merge(src proto.Message)

+ func (m *Device) XXX_Size() int

+ func (m *Device) XXX_Unmarshal(b []byte) error

+ func (s *Device) GetId() DeviceID

+ func (s *Device) GetType() DeviceType

+ type DeviceID string

+ type DeviceIndex uint

+ type DevicePin struct

+ DeviceId DeviceID

+ Index DeviceIndex

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DevicePin) Descriptor() ([]byte, []int)

+ func (*DevicePin) ProtoMessage()

+ func (m *DevicePin) Marshal() (dAtA []byte, err error)

+ func (m *DevicePin) MarshalTo(dAtA []byte) (int, error)

+ func (m *DevicePin) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DevicePin) Reset()

+ func (m *DevicePin) Size() (n int)

+ func (m *DevicePin) String() string

+ func (m *DevicePin) Unmarshal(dAtA []byte) error

+ func (m *DevicePin) XXX_DiscardUnknown()

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

+ func (m *DevicePin) XXX_Merge(src proto.Message)

+ func (m *DevicePin) XXX_Size() int

+ func (m *DevicePin) XXX_Unmarshal(b []byte) error

+ func (s *DevicePin) GetDeviceId() DeviceID

+ func (s *DevicePin) GetDeviceIndex() DeviceIndex

+ type DeviceType string

+ const DeviceTypeMCP23008

+ const DeviceTypeMCP23017

+ const DeviceTypePCA9685

+ func (t DeviceType) Validate() error

+ type Empty struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Marshal() (dAtA []byte, err error)

+ func (m *Empty) MarshalTo(dAtA []byte) (int, error)

+ func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) String() string

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ func (m *Empty) XXX_DiscardUnknown()

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

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

+ func (m *Empty) XXX_Size() int

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

+ type GetLogsRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetLogsRequest) Descriptor() ([]byte, []int)

+ func (*GetLogsRequest) ProtoMessage()

+ func (m *GetLogsRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetLogsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetLogsRequest) Reset()

+ func (m *GetLogsRequest) Size() (n int)

+ func (m *GetLogsRequest) String() string

+ func (m *GetLogsRequest) Unmarshal(dAtA []byte) error

+ func (m *GetLogsRequest) XXX_DiscardUnknown()

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

+ func (m *GetLogsRequest) XXX_Merge(src proto.Message)

+ func (m *GetLogsRequest) XXX_Size() int

+ func (m *GetLogsRequest) XXX_Unmarshal(b []byte) error

+ type Loc struct

+ Actual *LocState

+ Address ObjectAddress

+ Request *LocState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Loc) Descriptor() ([]byte, []int)

+ func (*Loc) ProtoMessage()

+ func (m *Loc) GetActual() *LocState

+ func (m *Loc) GetRequest() *LocState

+ func (m *Loc) Marshal() (dAtA []byte, err error)

+ func (m *Loc) MarshalTo(dAtA []byte) (int, error)

+ func (m *Loc) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Loc) Reset()

+ func (m *Loc) Size() (n int)

+ func (m *Loc) String() string

+ func (m *Loc) Unmarshal(dAtA []byte) error

+ func (m *Loc) XXX_DiscardUnknown()

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

+ func (m *Loc) XXX_Merge(src proto.Message)

+ func (m *Loc) XXX_Size() int

+ func (m *Loc) XXX_Unmarshal(b []byte) error

+ func (s *Loc) Clone() *Loc

+ func (s *Loc) Equal(o *Loc) bool

+ func (s *Loc) GetAddress() ObjectAddress

+ type LocDirection int32

+ const LocDirection_FORWARD

+ const LocDirection_REVERSE

+ func (LocDirection) EnumDescriptor() ([]byte, []int)

+ func (x LocDirection) String() string

+ type LocRequestsOptions struct

+ ManualConfirm bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LocRequestsOptions) Descriptor() ([]byte, []int)

+ func (*LocRequestsOptions) ProtoMessage()

+ func (m *LocRequestsOptions) GetManualConfirm() bool

+ func (m *LocRequestsOptions) Marshal() (dAtA []byte, err error)

+ func (m *LocRequestsOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *LocRequestsOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LocRequestsOptions) Reset()

+ func (m *LocRequestsOptions) Size() (n int)

+ func (m *LocRequestsOptions) String() string

+ func (m *LocRequestsOptions) Unmarshal(dAtA []byte) error

+ func (m *LocRequestsOptions) XXX_DiscardUnknown()

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

+ func (m *LocRequestsOptions) XXX_Merge(src proto.Message)

+ func (m *LocRequestsOptions) XXX_Size() int

+ func (m *LocRequestsOptions) XXX_Unmarshal(b []byte) error

+ type LocState struct

+ Direction LocDirection

+ Functions map[int32]bool

+ Speed int32

+ SpeedSteps int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LocState) Descriptor() ([]byte, []int)

+ func (*LocState) ProtoMessage()

+ func (m *LocState) GetDirection() LocDirection

+ func (m *LocState) GetFunctions() map[int32]bool

+ func (m *LocState) GetSpeed() int32

+ func (m *LocState) GetSpeedSteps() int32

+ func (m *LocState) Marshal() (dAtA []byte, err error)

+ func (m *LocState) MarshalTo(dAtA []byte) (int, error)

+ func (m *LocState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LocState) Reset()

+ func (m *LocState) Size() (n int)

+ func (m *LocState) String() string

+ func (m *LocState) Unmarshal(dAtA []byte) error

+ func (m *LocState) XXX_DiscardUnknown()

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

+ func (m *LocState) XXX_Merge(src proto.Message)

+ func (m *LocState) XXX_Size() int

+ func (m *LocState) XXX_Unmarshal(b []byte) error

+ func (s *LocState) Clone() *LocState

+ func (s *LocState) Equal(o *LocState) bool

+ type LocalWorkerConfig struct

+ Alias string

+ Devices []*Device

+ Objects []*Object

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LocalWorkerConfig) Descriptor() ([]byte, []int)

+ func (*LocalWorkerConfig) ProtoMessage()

+ func (c LocalWorkerConfig) DeviceByID(id DeviceID) (*Device, bool)

+ func (c LocalWorkerConfig) ObjectByID(id ObjectID) (*Object, bool)

+ func (c LocalWorkerConfig) Validate() error

+ func (m *LocalWorkerConfig) GetAlias() string

+ func (m *LocalWorkerConfig) GetDevices() []*Device

+ func (m *LocalWorkerConfig) GetObjects() []*Object

+ func (m *LocalWorkerConfig) Marshal() (dAtA []byte, err error)

+ func (m *LocalWorkerConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *LocalWorkerConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LocalWorkerConfig) Reset()

+ func (m *LocalWorkerConfig) Size() (n int)

+ func (m *LocalWorkerConfig) String() string

+ func (m *LocalWorkerConfig) Unmarshal(dAtA []byte) error

+ func (m *LocalWorkerConfig) XXX_DiscardUnknown()

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

+ func (m *LocalWorkerConfig) XXX_Merge(src proto.Message)

+ func (m *LocalWorkerConfig) XXX_Size() int

+ func (m *LocalWorkerConfig) XXX_Unmarshal(b []byte) error

+ type LocalWorkerConfigServiceClient interface

+ GetConfig func(ctx context.Context, in *LocalWorkerInfo, opts ...grpc.CallOption) (LocalWorkerConfigService_GetConfigClient, error)

+ func NewLocalWorkerConfigServiceClient(cc *grpc.ClientConn) LocalWorkerConfigServiceClient

+ type LocalWorkerConfigServiceServer interface

+ GetConfig func(*LocalWorkerInfo, LocalWorkerConfigService_GetConfigServer) error

+ type LocalWorkerConfigService_GetConfigClient interface

+ Recv func() (*LocalWorkerConfig, error)

+ type LocalWorkerConfigService_GetConfigServer interface

+ Send func(*LocalWorkerConfig) error

+ type LocalWorkerControlServiceClient interface

+ GetClock func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (LocalWorkerControlService_GetClockClient, error)

+ GetLocRequests func(ctx context.Context, in *LocRequestsOptions, opts ...grpc.CallOption) (LocalWorkerControlService_GetLocRequestsClient, error)

+ GetOutputRequests func(ctx context.Context, in *OutputRequestsOptions, opts ...grpc.CallOption) (LocalWorkerControlService_GetOutputRequestsClient, error)

+ GetPowerRequests func(ctx context.Context, in *PowerRequestsOptions, opts ...grpc.CallOption) (LocalWorkerControlService_GetPowerRequestsClient, error)

+ GetSwitchRequests func(ctx context.Context, in *SwitchRequestsOptions, opts ...grpc.CallOption) (LocalWorkerControlService_GetSwitchRequestsClient, error)

+ Ping func(ctx context.Context, in *LocalWorkerInfo, opts ...grpc.CallOption) (*Empty, error)

+ SetLocActuals func(ctx context.Context, opts ...grpc.CallOption) (LocalWorkerControlService_SetLocActualsClient, error)

+ SetOutputActuals func(ctx context.Context, opts ...grpc.CallOption) (LocalWorkerControlService_SetOutputActualsClient, error)

+ SetPowerActuals func(ctx context.Context, opts ...grpc.CallOption) (LocalWorkerControlService_SetPowerActualsClient, error)

+ SetSensorActuals func(ctx context.Context, opts ...grpc.CallOption) (LocalWorkerControlService_SetSensorActualsClient, error)

+ SetSwitchActuals func(ctx context.Context, opts ...grpc.CallOption) (LocalWorkerControlService_SetSwitchActualsClient, error)

+ func NewLocalWorkerControlServiceClient(cc *grpc.ClientConn) LocalWorkerControlServiceClient

+ type LocalWorkerControlServiceServer interface

+ GetClock func(*Empty, LocalWorkerControlService_GetClockServer) error

+ GetLocRequests func(*LocRequestsOptions, LocalWorkerControlService_GetLocRequestsServer) error

+ GetOutputRequests func(*OutputRequestsOptions, LocalWorkerControlService_GetOutputRequestsServer) error

+ GetPowerRequests func(*PowerRequestsOptions, LocalWorkerControlService_GetPowerRequestsServer) error

+ GetSwitchRequests func(*SwitchRequestsOptions, LocalWorkerControlService_GetSwitchRequestsServer) error

+ Ping func(context.Context, *LocalWorkerInfo) (*Empty, error)

+ SetLocActuals func(LocalWorkerControlService_SetLocActualsServer) error

+ SetOutputActuals func(LocalWorkerControlService_SetOutputActualsServer) error

+ SetPowerActuals func(LocalWorkerControlService_SetPowerActualsServer) error

+ SetSensorActuals func(LocalWorkerControlService_SetSensorActualsServer) error

+ SetSwitchActuals func(LocalWorkerControlService_SetSwitchActualsServer) error

+ type LocalWorkerControlService_GetClockClient interface

+ Recv func() (*Clock, error)

+ type LocalWorkerControlService_GetClockServer interface

+ Send func(*Clock) error

+ type LocalWorkerControlService_GetLocRequestsClient interface

+ Recv func() (*Loc, error)

+ type LocalWorkerControlService_GetLocRequestsServer interface

+ Send func(*Loc) error

+ type LocalWorkerControlService_GetOutputRequestsClient interface

+ Recv func() (*Output, error)

+ type LocalWorkerControlService_GetOutputRequestsServer interface

+ Send func(*Output) error

+ type LocalWorkerControlService_GetPowerRequestsClient interface

+ Recv func() (*PowerState, error)

+ type LocalWorkerControlService_GetPowerRequestsServer interface

+ Send func(*PowerState) error

+ type LocalWorkerControlService_GetSwitchRequestsClient interface

+ Recv func() (*Switch, error)

+ type LocalWorkerControlService_GetSwitchRequestsServer interface

+ Send func(*Switch) error

+ type LocalWorkerControlService_SetLocActualsClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*Loc) error

+ type LocalWorkerControlService_SetLocActualsServer interface

+ Recv func() (*Loc, error)

+ SendAndClose func(*Empty) error

+ type LocalWorkerControlService_SetOutputActualsClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*Output) error

+ type LocalWorkerControlService_SetOutputActualsServer interface

+ Recv func() (*Output, error)

+ SendAndClose func(*Empty) error

+ type LocalWorkerControlService_SetPowerActualsClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*PowerState) error

+ type LocalWorkerControlService_SetPowerActualsServer interface

+ Recv func() (*PowerState, error)

+ SendAndClose func(*Empty) error

+ type LocalWorkerControlService_SetSensorActualsClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*Sensor) error

+ type LocalWorkerControlService_SetSensorActualsServer interface

+ Recv func() (*Sensor, error)

+ SendAndClose func(*Empty) error

+ type LocalWorkerControlService_SetSwitchActualsClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*Switch) error

+ type LocalWorkerControlService_SetSwitchActualsServer interface

+ Recv func() (*Switch, error)

+ SendAndClose func(*Empty) error

+ type LocalWorkerInfo struct

+ Description string

+ Id string

+ Uptime int64

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LocalWorkerInfo) Descriptor() ([]byte, []int)

+ func (*LocalWorkerInfo) ProtoMessage()

+ func (m *LocalWorkerInfo) GetDescription() string

+ func (m *LocalWorkerInfo) GetId() string

+ func (m *LocalWorkerInfo) GetUptime() int64

+ func (m *LocalWorkerInfo) GetVersion() string

+ func (m *LocalWorkerInfo) Marshal() (dAtA []byte, err error)

+ func (m *LocalWorkerInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *LocalWorkerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LocalWorkerInfo) Reset()

+ func (m *LocalWorkerInfo) Size() (n int)

+ func (m *LocalWorkerInfo) String() string

+ func (m *LocalWorkerInfo) Unmarshal(dAtA []byte) error

+ func (m *LocalWorkerInfo) XXX_DiscardUnknown()

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

+ func (m *LocalWorkerInfo) XXX_Merge(src proto.Message)

+ func (m *LocalWorkerInfo) XXX_Size() int

+ func (m *LocalWorkerInfo) XXX_Unmarshal(b []byte) error

+ type LogEntry struct

+ Message string

+ String_ LogLevel

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogEntry) Descriptor() ([]byte, []int)

+ func (*LogEntry) ProtoMessage()

+ func (m *LogEntry) GetMessage() string

+ func (m *LogEntry) GetString_() LogLevel

+ func (m *LogEntry) Marshal() (dAtA []byte, err error)

+ func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogEntry) Reset()

+ func (m *LogEntry) Size() (n int)

+ func (m *LogEntry) String() string

+ func (m *LogEntry) Unmarshal(dAtA []byte) error

+ func (m *LogEntry) XXX_DiscardUnknown()

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

+ func (m *LogEntry) XXX_Merge(src proto.Message)

+ func (m *LogEntry) XXX_Size() int

+ func (m *LogEntry) XXX_Unmarshal(b []byte) error

+ type LogLevel int32

+ const LogLevel_DEBUG

+ const LogLevel_ERROR

+ const LogLevel_FATAL

+ const LogLevel_INFO

+ const LogLevel_TRACE

+ const LogLevel_WARNING

+ func (LogLevel) EnumDescriptor() ([]byte, []int)

+ func (x LogLevel) String() string

+ type LogProviderServiceClient interface

+ GetLogs func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (LogProviderService_GetLogsClient, error)

+ func NewLogProviderServiceClient(cc *grpc.ClientConn) LogProviderServiceClient

+ type LogProviderServiceServer interface

+ GetLogs func(*GetLogsRequest, LogProviderService_GetLogsServer) error

+ type LogProviderService_GetLogsClient interface

+ Recv func() (*LogEntry, error)

+ type LogProviderService_GetLogsServer interface

+ Send func(*LogEntry) error

+ type NetworkControlServiceClient interface

+ Clock func(ctx context.Context, opts ...grpc.CallOption) (NetworkControlService_ClockClient, error)

+ Locs func(ctx context.Context, opts ...grpc.CallOption) (NetworkControlService_LocsClient, error)

+ Outputs func(ctx context.Context, opts ...grpc.CallOption) (NetworkControlService_OutputsClient, error)

+ Power func(ctx context.Context, opts ...grpc.CallOption) (NetworkControlService_PowerClient, error)

+ Sensors func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (NetworkControlService_SensorsClient, error)

+ Switches func(ctx context.Context, opts ...grpc.CallOption) (NetworkControlService_SwitchesClient, error)

+ func NewNetworkControlServiceClient(cc *grpc.ClientConn) NetworkControlServiceClient

+ type NetworkControlServiceServer interface

+ Clock func(NetworkControlService_ClockServer) error

+ Locs func(NetworkControlService_LocsServer) error

+ Outputs func(NetworkControlService_OutputsServer) error

+ Power func(NetworkControlService_PowerServer) error

+ Sensors func(*Empty, NetworkControlService_SensorsServer) error

+ Switches func(NetworkControlService_SwitchesServer) error

+ type NetworkControlService_ClockClient interface

+ Recv func() (*Clock, error)

+ Send func(*Clock) error

+ type NetworkControlService_ClockServer interface

+ Recv func() (*Clock, error)

+ Send func(*Clock) error

+ type NetworkControlService_LocsClient interface

+ Recv func() (*Loc, error)

+ Send func(*Loc) error

+ type NetworkControlService_LocsServer interface

+ Recv func() (*Loc, error)

+ Send func(*Loc) error

+ type NetworkControlService_OutputsClient interface

+ Recv func() (*Output, error)

+ Send func(*Output) error

+ type NetworkControlService_OutputsServer interface

+ Recv func() (*Output, error)

+ Send func(*Output) error

+ type NetworkControlService_PowerClient interface

+ Recv func() (*Power, error)

+ Send func(*PowerState) error

+ type NetworkControlService_PowerServer interface

+ Recv func() (*PowerState, error)

+ Send func(*Power) error

+ type NetworkControlService_SensorsClient interface

+ Recv func() (*Sensor, error)

+ type NetworkControlService_SensorsServer interface

+ Send func(*Sensor) error

+ type NetworkControlService_SwitchesClient interface

+ Recv func() (*Switch, error)

+ Send func(*Switch) error

+ type NetworkControlService_SwitchesServer interface

+ Recv func() (*Switch, error)

+ Send func(*Switch) error

+ type Object struct

+ Connections []*Connection

+ Id ObjectID

+ Type ObjectType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Object) Descriptor() ([]byte, []int)

+ func (*Object) ProtoMessage()

+ func (m *Object) GetConnections() []*Connection

+ func (m *Object) Marshal() (dAtA []byte, err error)

+ func (m *Object) MarshalTo(dAtA []byte) (int, error)

+ func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Object) Reset()

+ func (m *Object) Size() (n int)

+ func (m *Object) String() string

+ func (m *Object) Unmarshal(dAtA []byte) error

+ func (m *Object) XXX_DiscardUnknown()

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

+ func (m *Object) XXX_Merge(src proto.Message)

+ func (m *Object) XXX_Size() int

+ func (m *Object) XXX_Unmarshal(b []byte) error

+ func (o Object) ConnectionByName(name ConnectionName) (*Connection, bool)

+ func (o Object) Validate() error

+ func (s *Object) GetId() ObjectID

+ func (s *Object) GetType() ObjectType

+ type ObjectAddress string

+ func JoinModuleLocal(module, local string) ObjectAddress

+ type ObjectConnectionInfo struct

+ Name ConnectionName

+ PinCount int

+ Required bool

+ type ObjectID string

+ type ObjectType string

+ const ObjectTypeBinaryOutput

+ const ObjectTypeBinarySensor

+ const ObjectTypeRelaySwitch

+ const ObjectTypeServoSwitch

+ func (t ObjectType) TypeInfo() ObjectTypeInfo

+ func (t ObjectType) Validate() error

+ type ObjectTypeInfo struct

+ Connections []ObjectConnectionInfo

+ Description string

+ Type ObjectType

+ func (i ObjectTypeInfo) ConnectionByName(name ConnectionName) (ObjectConnectionInfo, bool)

+ type Output struct

+ Actual *OutputState

+ Address ObjectAddress

+ Request *OutputState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Output) ProtoMessage()

+ func (m *Output) GetActual() *OutputState

+ func (m *Output) GetRequest() *OutputState

+ func (m *Output) Marshal() (dAtA []byte, err error)

+ func (m *Output) MarshalTo(dAtA []byte) (int, error)

+ func (m *Output) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Output) Reset()

+ func (m *Output) Size() (n int)

+ func (m *Output) String() string

+ func (m *Output) Unmarshal(dAtA []byte) error

+ func (m *Output) XXX_DiscardUnknown()

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

+ func (m *Output) XXX_Merge(src proto.Message)

+ func (m *Output) XXX_Size() int

+ func (m *Output) XXX_Unmarshal(b []byte) error

+ func (s *Output) Clone() *Output

+ func (s *Output) Equal(o *Output) bool

+ func (s *Output) GetAddress() ObjectAddress

+ type OutputRequestsOptions struct

+ ManualConfirm bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OutputRequestsOptions) Descriptor() ([]byte, []int)

+ func (*OutputRequestsOptions) ProtoMessage()

+ func (m *OutputRequestsOptions) GetManualConfirm() bool

+ func (m *OutputRequestsOptions) Marshal() (dAtA []byte, err error)

+ func (m *OutputRequestsOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputRequestsOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutputRequestsOptions) Reset()

+ func (m *OutputRequestsOptions) Size() (n int)

+ func (m *OutputRequestsOptions) String() string

+ func (m *OutputRequestsOptions) Unmarshal(dAtA []byte) error

+ func (m *OutputRequestsOptions) XXX_DiscardUnknown()

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

+ func (m *OutputRequestsOptions) XXX_Merge(src proto.Message)

+ func (m *OutputRequestsOptions) XXX_Size() int

+ func (m *OutputRequestsOptions) XXX_Unmarshal(b []byte) error

+ type OutputState struct

+ Value int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OutputState) Descriptor() ([]byte, []int)

+ func (*OutputState) ProtoMessage()

+ func (m *OutputState) GetValue() int32

+ func (m *OutputState) Marshal() (dAtA []byte, err error)

+ func (m *OutputState) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutputState) Reset()

+ func (m *OutputState) Size() (n int)

+ func (m *OutputState) String() string

+ func (m *OutputState) Unmarshal(dAtA []byte) error

+ func (m *OutputState) XXX_DiscardUnknown()

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

+ func (m *OutputState) XXX_Merge(src proto.Message)

+ func (m *OutputState) XXX_Size() int

+ func (m *OutputState) XXX_Unmarshal(b []byte) error

+ func (s *OutputState) Clone() *OutputState

+ func (s *OutputState) Equal(o *OutputState) bool

+ type Power struct

+ Actual *PowerState

+ Request *PowerState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Power) Descriptor() ([]byte, []int)

+ func (*Power) ProtoMessage()

+ func (m *Power) GetActual() *PowerState

+ func (m *Power) GetRequest() *PowerState

+ func (m *Power) Marshal() (dAtA []byte, err error)

+ func (m *Power) MarshalTo(dAtA []byte) (int, error)

+ func (m *Power) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Power) Reset()

+ func (m *Power) Size() (n int)

+ func (m *Power) String() string

+ func (m *Power) Unmarshal(dAtA []byte) error

+ func (m *Power) XXX_DiscardUnknown()

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

+ func (m *Power) XXX_Merge(src proto.Message)

+ func (m *Power) XXX_Size() int

+ func (m *Power) XXX_Unmarshal(b []byte) error

+ func (s *Power) Clone() *Power

+ func (s *Power) Equal(o *Power) bool

+ type PowerRequestsOptions struct

+ ManualConfirm bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PowerRequestsOptions) Descriptor() ([]byte, []int)

+ func (*PowerRequestsOptions) ProtoMessage()

+ func (m *PowerRequestsOptions) GetManualConfirm() bool

+ func (m *PowerRequestsOptions) Marshal() (dAtA []byte, err error)

+ func (m *PowerRequestsOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *PowerRequestsOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PowerRequestsOptions) Reset()

+ func (m *PowerRequestsOptions) Size() (n int)

+ func (m *PowerRequestsOptions) String() string

+ func (m *PowerRequestsOptions) Unmarshal(dAtA []byte) error

+ func (m *PowerRequestsOptions) XXX_DiscardUnknown()

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

+ func (m *PowerRequestsOptions) XXX_Merge(src proto.Message)

+ func (m *PowerRequestsOptions) XXX_Size() int

+ func (m *PowerRequestsOptions) XXX_Unmarshal(b []byte) error

+ type PowerState struct

+ Enabled bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PowerState) Descriptor() ([]byte, []int)

+ func (*PowerState) ProtoMessage()

+ func (m *PowerState) GetEnabled() bool

+ func (m *PowerState) Marshal() (dAtA []byte, err error)

+ func (m *PowerState) MarshalTo(dAtA []byte) (int, error)

+ func (m *PowerState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PowerState) Reset()

+ func (m *PowerState) Size() (n int)

+ func (m *PowerState) String() string

+ func (m *PowerState) Unmarshal(dAtA []byte) error

+ func (m *PowerState) XXX_DiscardUnknown()

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

+ func (m *PowerState) XXX_Merge(src proto.Message)

+ func (m *PowerState) XXX_Size() int

+ func (m *PowerState) XXX_Unmarshal(b []byte) error

+ func (s *PowerState) Clone() *PowerState

+ func (s *PowerState) Equal(o *PowerState) bool

+ type Sensor struct

+ Actual *SensorState

+ Address ObjectAddress

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Sensor) Descriptor() ([]byte, []int)

+ func (*Sensor) ProtoMessage()

+ func (m *Sensor) GetActual() *SensorState

+ func (m *Sensor) Marshal() (dAtA []byte, err error)

+ func (m *Sensor) MarshalTo(dAtA []byte) (int, error)

+ func (m *Sensor) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Sensor) Reset()

+ func (m *Sensor) Size() (n int)

+ func (m *Sensor) String() string

+ func (m *Sensor) Unmarshal(dAtA []byte) error

+ func (m *Sensor) XXX_DiscardUnknown()

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

+ func (m *Sensor) XXX_Merge(src proto.Message)

+ func (m *Sensor) XXX_Size() int

+ func (m *Sensor) XXX_Unmarshal(b []byte) error

+ func (s *Sensor) Clone() *Sensor

+ func (s *Sensor) Equal(o *Sensor) bool

+ func (s *Sensor) GetAddress() ObjectAddress

+ type SensorState struct

+ Value int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SensorState) Descriptor() ([]byte, []int)

+ func (*SensorState) ProtoMessage()

+ func (m *SensorState) GetValue() int32

+ func (m *SensorState) Marshal() (dAtA []byte, err error)

+ func (m *SensorState) MarshalTo(dAtA []byte) (int, error)

+ func (m *SensorState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SensorState) Reset()

+ func (m *SensorState) Size() (n int)

+ func (m *SensorState) String() string

+ func (m *SensorState) Unmarshal(dAtA []byte) error

+ func (m *SensorState) XXX_DiscardUnknown()

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

+ func (m *SensorState) XXX_Merge(src proto.Message)

+ func (m *SensorState) XXX_Size() int

+ func (m *SensorState) XXX_Unmarshal(b []byte) error

+ func (s *SensorState) Clone() *SensorState

+ func (s *SensorState) Equal(o *SensorState) bool

+ type ServiceInfo struct

+ ApiAddress string

+ ApiPort int32

+ ApiVersion string

+ Secure bool

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func ParseServiceInfo(se *zeroconf.ServiceEntry) (*ServiceInfo, error)

+ func (*ServiceInfo) Descriptor() ([]byte, []int)

+ func (*ServiceInfo) ProtoMessage()

+ func (m *ServiceInfo) GetApiAddress() string

+ func (m *ServiceInfo) GetApiPort() int32

+ func (m *ServiceInfo) GetApiVersion() string

+ func (m *ServiceInfo) GetSecure() bool

+ func (m *ServiceInfo) GetVersion() string

+ func (m *ServiceInfo) Marshal() (dAtA []byte, err error)

+ func (m *ServiceInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceInfo) Reset()

+ func (m *ServiceInfo) Size() (n int)

+ func (m *ServiceInfo) String() string

+ func (m *ServiceInfo) Unmarshal(dAtA []byte) error

+ func (m *ServiceInfo) XXX_DiscardUnknown()

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

+ func (m *ServiceInfo) XXX_Merge(src proto.Message)

+ func (m *ServiceInfo) XXX_Size() int

+ func (m *ServiceInfo) XXX_Unmarshal(b []byte) error

+ type Switch struct

+ Actual *SwitchState

+ Address ObjectAddress

+ Request *SwitchState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Switch) Descriptor() ([]byte, []int)

+ func (*Switch) ProtoMessage()

+ func (m *Switch) GetActual() *SwitchState

+ func (m *Switch) GetRequest() *SwitchState

+ func (m *Switch) Marshal() (dAtA []byte, err error)

+ func (m *Switch) MarshalTo(dAtA []byte) (int, error)

+ func (m *Switch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Switch) Reset()

+ func (m *Switch) Size() (n int)

+ func (m *Switch) String() string

+ func (m *Switch) Unmarshal(dAtA []byte) error

+ func (m *Switch) XXX_DiscardUnknown()

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

+ func (m *Switch) XXX_Merge(src proto.Message)

+ func (m *Switch) XXX_Size() int

+ func (m *Switch) XXX_Unmarshal(b []byte) error

+ func (s *Switch) Clone() *Switch

+ func (s *Switch) Equal(o *Switch) bool

+ func (s *Switch) GetAddress() ObjectAddress

+ type SwitchDirection int32

+ const SwitchDirection_OFF

+ const SwitchDirection_STRAIGHT

+ func (SwitchDirection) EnumDescriptor() ([]byte, []int)

+ func (x SwitchDirection) String() string

+ type SwitchRequestsOptions struct

+ ManualConfirm bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SwitchRequestsOptions) Descriptor() ([]byte, []int)

+ func (*SwitchRequestsOptions) ProtoMessage()

+ func (m *SwitchRequestsOptions) GetManualConfirm() bool

+ func (m *SwitchRequestsOptions) Marshal() (dAtA []byte, err error)

+ func (m *SwitchRequestsOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *SwitchRequestsOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SwitchRequestsOptions) Reset()

+ func (m *SwitchRequestsOptions) Size() (n int)

+ func (m *SwitchRequestsOptions) String() string

+ func (m *SwitchRequestsOptions) Unmarshal(dAtA []byte) error

+ func (m *SwitchRequestsOptions) XXX_DiscardUnknown()

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

+ func (m *SwitchRequestsOptions) XXX_Merge(src proto.Message)

+ func (m *SwitchRequestsOptions) XXX_Size() int

+ func (m *SwitchRequestsOptions) XXX_Unmarshal(b []byte) error

+ type SwitchState struct

+ Direction SwitchDirection

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SwitchState) Descriptor() ([]byte, []int)

+ func (*SwitchState) ProtoMessage()

+ func (m *SwitchState) GetDirection() SwitchDirection

+ func (m *SwitchState) Marshal() (dAtA []byte, err error)

+ func (m *SwitchState) MarshalTo(dAtA []byte) (int, error)

+ func (m *SwitchState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SwitchState) Reset()

+ func (m *SwitchState) Size() (n int)

+ func (m *SwitchState) String() string

+ func (m *SwitchState) Unmarshal(dAtA []byte) error

+ func (m *SwitchState) XXX_DiscardUnknown()

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

+ func (m *SwitchState) XXX_Merge(src proto.Message)

+ func (m *SwitchState) XXX_Size() int

+ func (m *SwitchState) XXX_Unmarshal(b []byte) error

+ func (s *SwitchState) Clone() *SwitchState

+ func (s *SwitchState) Equal(o *SwitchState) bool

+ type TimePeriod int32

+ const TimePeriod_AFTERNOON

+ const TimePeriod_EVENING

+ const TimePeriod_MORNING

+ const TimePeriod_NIGHT

+ func (TimePeriod) EnumDescriptor() ([]byte, []int)

+ func (x TimePeriod) String() string

+ type UnimplementedCommandStationServiceServer struct

+ func (*UnimplementedCommandStationServiceServer) GetInfo(ctx context.Context, req *Empty) (*CommandStationInfo, error)

+ func (*UnimplementedCommandStationServiceServer) GetLocActuals(req *Empty, srv CommandStationService_GetLocActualsServer) error

+ func (*UnimplementedCommandStationServiceServer) GetPowerActuals(req *Empty, srv CommandStationService_GetPowerActualsServer) error

+ func (*UnimplementedCommandStationServiceServer) SetLoc(ctx context.Context, req *Loc) (*Empty, error)

+ func (*UnimplementedCommandStationServiceServer) SetPower(ctx context.Context, req *PowerState) (*Empty, error)

+ type UnimplementedLocalWorkerConfigServiceServer struct

+ func (*UnimplementedLocalWorkerConfigServiceServer) GetConfig(req *LocalWorkerInfo, srv LocalWorkerConfigService_GetConfigServer) error

+ type UnimplementedLocalWorkerControlServiceServer struct

+ func (*UnimplementedLocalWorkerControlServiceServer) GetClock(req *Empty, srv LocalWorkerControlService_GetClockServer) error

+ func (*UnimplementedLocalWorkerControlServiceServer) GetLocRequests(req *LocRequestsOptions, srv LocalWorkerControlService_GetLocRequestsServer) error

+ func (*UnimplementedLocalWorkerControlServiceServer) GetOutputRequests(req *OutputRequestsOptions, ...) error

+ func (*UnimplementedLocalWorkerControlServiceServer) GetPowerRequests(req *PowerRequestsOptions, ...) error

+ func (*UnimplementedLocalWorkerControlServiceServer) GetSwitchRequests(req *SwitchRequestsOptions, ...) error

+ func (*UnimplementedLocalWorkerControlServiceServer) Ping(ctx context.Context, req *LocalWorkerInfo) (*Empty, error)

+ func (*UnimplementedLocalWorkerControlServiceServer) SetLocActuals(srv LocalWorkerControlService_SetLocActualsServer) error

+ func (*UnimplementedLocalWorkerControlServiceServer) SetOutputActuals(srv LocalWorkerControlService_SetOutputActualsServer) error

+ func (*UnimplementedLocalWorkerControlServiceServer) SetPowerActuals(srv LocalWorkerControlService_SetPowerActualsServer) error

+ func (*UnimplementedLocalWorkerControlServiceServer) SetSensorActuals(srv LocalWorkerControlService_SetSensorActualsServer) error

+ func (*UnimplementedLocalWorkerControlServiceServer) SetSwitchActuals(srv LocalWorkerControlService_SetSwitchActualsServer) error

+ type UnimplementedLogProviderServiceServer struct

+ func (*UnimplementedLogProviderServiceServer) GetLogs(req *GetLogsRequest, srv LogProviderService_GetLogsServer) error

+ type UnimplementedNetworkControlServiceServer struct

+ func (*UnimplementedNetworkControlServiceServer) Clock(srv NetworkControlService_ClockServer) error

+ func (*UnimplementedNetworkControlServiceServer) Locs(srv NetworkControlService_LocsServer) error

+ func (*UnimplementedNetworkControlServiceServer) Outputs(srv NetworkControlService_OutputsServer) error

+ func (*UnimplementedNetworkControlServiceServer) Power(srv NetworkControlService_PowerServer) error

+ func (*UnimplementedNetworkControlServiceServer) Sensors(req *Empty, srv NetworkControlService_SensorsServer) error

+ func (*UnimplementedNetworkControlServiceServer) Switches(srv NetworkControlService_SwitchesServer) error

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