synerex_api

package module

Go to main page

Versions in this module

v0

v0.5.1

Dec 3, 2021

v0.5.0

Dec 3, 2021

Changes in this version

type SynerexClient

+ SelectModifiedSupply func(ctx context.Context, in *Supply, opts ...grpc.CallOption) (*ConfirmResponse, error)

type SynerexServer

+ SelectModifiedSupply func(context.Context, *Supply) (*ConfirmResponse, error)

type UnimplementedSynerexServer

+ func (*UnimplementedSynerexServer) SelectModifiedSupply(context.Context, *Supply) (*ConfirmResponse, error)

v0.4.3

May 29, 2021

v0.4.2

Aug 22, 2020

v0.4.1

Jul 22, 2020

Changes in this version

type SynerexClient

+ SendMbusMsg func(ctx context.Context, in *MbusMsg, opts ...grpc.CallOption) (*Response, error)

type SynerexServer

+ SendMbusMsg func(context.Context, *MbusMsg) (*Response, error)

type UnimplementedSynerexServer

+ func (*UnimplementedSynerexServer) SendMbusMsg(context.Context, *MbusMsg) (*Response, error)

v0.4.0

Jul 22, 2020

Changes in this version

+ var File_synerex_proto protoreflect.FileDescriptor

+ var MbusOpt_MbusType_name = map[int32]string

+ var MbusOpt_MbusType_value = map[string]int32

+ var MbusState_MbusStatus_name = map[int32]string

+ var MbusState_MbusStatus_value = map[string]int32

type Channel

+ func (x *Channel) ProtoReflect() protoreflect.Message

type ConfirmResponse

+ func (x *ConfirmResponse) ProtoReflect() protoreflect.Message

type Content

+ func (x *Content) ProtoReflect() protoreflect.Message

type Demand

+ func (x *Demand) ProtoReflect() protoreflect.Message

type GatewayInfo

+ func (x *GatewayInfo) ProtoReflect() protoreflect.Message

type GatewayMsg

+ func (x *GatewayMsg) ProtoReflect() protoreflect.Message

type GatewayType

+ func (GatewayType) Descriptor() protoreflect.EnumDescriptor

+ func (GatewayType) Type() protoreflect.EnumType

+ func (x GatewayType) Enum() *GatewayType

+ func (x GatewayType) Number() protoreflect.EnumNumber

type Mbus

+ func (x *Mbus) ProtoReflect() protoreflect.Message

type MbusMsg

+ Cdata *Content

+ func (x *MbusMsg) GetCdata() *Content

+ func (x *MbusMsg) ProtoReflect() protoreflect.Message

+ type MbusOpt struct

+ MbusType MbusOpt_MbusType

+ Subscribers []uint64

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

+ func (*MbusOpt) ProtoMessage()

+ func (x *MbusOpt) GetMbusType() MbusOpt_MbusType

+ func (x *MbusOpt) GetSubscribers() []uint64

+ func (x *MbusOpt) ProtoReflect() protoreflect.Message

+ func (x *MbusOpt) Reset()

+ func (x *MbusOpt) String() string

+ type MbusOpt_MbusType int32

+ const MbusOpt_PRIVATE

+ const MbusOpt_PUBLIC

+ func (MbusOpt_MbusType) Descriptor() protoreflect.EnumDescriptor

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

+ func (MbusOpt_MbusType) Type() protoreflect.EnumType

+ func (x MbusOpt_MbusType) Enum() *MbusOpt_MbusType

+ func (x MbusOpt_MbusType) Number() protoreflect.EnumNumber

+ func (x MbusOpt_MbusType) String() string

+ type MbusState struct

+ MbusId uint64

+ Status MbusState_MbusStatus

+ Subscribers []uint64

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

+ func (*MbusState) ProtoMessage()

+ func (x *MbusState) GetMbusId() uint64

+ func (x *MbusState) GetStatus() MbusState_MbusStatus

+ func (x *MbusState) GetSubscribers() []uint64

+ func (x *MbusState) ProtoReflect() protoreflect.Message

+ func (x *MbusState) Reset()

+ func (x *MbusState) String() string

+ type MbusState_MbusStatus int32

+ const MbusState_CLOSED

+ const MbusState_INTIALIZED

+ const MbusState_INVALID

+ const MbusState_SUBSCRIBERS

+ func (MbusState_MbusStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (MbusState_MbusStatus) Type() protoreflect.EnumType

+ func (x MbusState_MbusStatus) Enum() *MbusState_MbusStatus

+ func (x MbusState_MbusStatus) Number() protoreflect.EnumNumber

+ func (x MbusState_MbusStatus) String() string

type MsgType

+ func (MsgType) Descriptor() protoreflect.EnumDescriptor

+ func (MsgType) Type() protoreflect.EnumType

+ func (x MsgType) Enum() *MsgType

+ func (x MsgType) Number() protoreflect.EnumNumber

type ProviderID

+ func (x *ProviderID) ProtoReflect() protoreflect.Message

type Response

+ func (x *Response) ProtoReflect() protoreflect.Message

type Supply

+ func (x *Supply) ProtoReflect() protoreflect.Message

type SynerexClient

+ CreateMbus func(ctx context.Context, in *MbusOpt, opts ...grpc.CallOption) (*Mbus, error)

+ GetMbusState func(ctx context.Context, in *Mbus, opts ...grpc.CallOption) (*MbusState, error)

type SynerexServer

+ CreateMbus func(context.Context, *MbusOpt) (*Mbus, error)

+ GetMbusState func(context.Context, *Mbus) (*MbusState, error)

type Target

+ func (x *Target) ProtoReflect() protoreflect.Message

+ type UnimplementedSynerexServer struct

+ func (*UnimplementedSynerexServer) CloseAllChannels(context.Context, *ProviderID) (*Response, error)

+ func (*UnimplementedSynerexServer) CloseDemandChannel(context.Context, *Channel) (*Response, error)

+ func (*UnimplementedSynerexServer) CloseMbus(context.Context, *Mbus) (*Response, error)

+ func (*UnimplementedSynerexServer) CloseSupplyChannel(context.Context, *Channel) (*Response, error)

+ func (*UnimplementedSynerexServer) Confirm(context.Context, *Target) (*Response, error)

+ func (*UnimplementedSynerexServer) CreateMbus(context.Context, *MbusOpt) (*Mbus, error)

+ func (*UnimplementedSynerexServer) ForwardToGateway(context.Context, *GatewayMsg) (*Response, error)

+ func (*UnimplementedSynerexServer) GetMbusState(context.Context, *Mbus) (*MbusState, error)

+ func (*UnimplementedSynerexServer) NotifyDemand(context.Context, *Demand) (*Response, error)

+ func (*UnimplementedSynerexServer) NotifySupply(context.Context, *Supply) (*Response, error)

+ func (*UnimplementedSynerexServer) ProposeDemand(context.Context, *Demand) (*Response, error)

+ func (*UnimplementedSynerexServer) ProposeSupply(context.Context, *Supply) (*Response, error)

+ func (*UnimplementedSynerexServer) SelectDemand(context.Context, *Target) (*ConfirmResponse, error)

+ func (*UnimplementedSynerexServer) SelectSupply(context.Context, *Target) (*ConfirmResponse, error)

+ func (*UnimplementedSynerexServer) SendMsg(context.Context, *MbusMsg) (*Response, error)

+ func (*UnimplementedSynerexServer) SubscribeDemand(*Channel, Synerex_SubscribeDemandServer) error

+ func (*UnimplementedSynerexServer) SubscribeGateway(*GatewayInfo, Synerex_SubscribeGatewayServer) error

+ func (*UnimplementedSynerexServer) SubscribeMbus(*Mbus, Synerex_SubscribeMbusServer) error

+ func (*UnimplementedSynerexServer) SubscribeSupply(*Channel, Synerex_SubscribeSupplyServer) error

v0.3.1

Jan 12, 2020

Changes in this version

+ type ProviderID struct

+ ArgJson string

+ ClientId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ProviderID) ProtoMessage()

+ func (dst *ProviderID) XXX_Merge(src proto.Message)

+ func (m *ProviderID) GetArgJson() string

+ func (m *ProviderID) GetClientId() uint64

+ func (m *ProviderID) Reset()

+ func (m *ProviderID) String() string

+ func (m *ProviderID) XXX_DiscardUnknown()

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

+ func (m *ProviderID) XXX_Size() int

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

type SynerexClient

+ CloseAllChannels func(ctx context.Context, in *ProviderID, opts ...grpc.CallOption) (*Response, error)

+ CloseDemandChannel func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (*Response, error)

+ CloseSupplyChannel func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (*Response, error)

type SynerexServer

+ CloseAllChannels func(context.Context, *ProviderID) (*Response, error)

+ CloseDemandChannel func(context.Context, *Channel) (*Response, error)

+ CloseSupplyChannel func(context.Context, *Channel) (*Response, error)

v0.2.1

Sep 25, 2019

Changes in this version

type GatewayInfo

+ Channels []uint32

+ ClientId uint64

+ func (m *GatewayInfo) GetChannels() []uint32

+ func (m *GatewayInfo) GetClientId() uint64

v0.1.1

Sep 25, 2019

Changes in this version

+ var GatewayType_name = map[int32]string

+ var GatewayType_value = map[string]int32

+ var MsgType_name = map[int32]string

+ var MsgType_value = map[string]int32

+ type GatewayInfo struct

+ GatewayType GatewayType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GatewayInfo) ProtoMessage()

+ func (dst *GatewayInfo) XXX_Merge(src proto.Message)

+ func (m *GatewayInfo) GetGatewayType() GatewayType

+ func (m *GatewayInfo) Reset()

+ func (m *GatewayInfo) String() string

+ func (m *GatewayInfo) XXX_DiscardUnknown()

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

+ func (m *GatewayInfo) XXX_Size() int

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

+ type GatewayMsg struct

+ MsgOneof isGatewayMsg_MsgOneof

+ MsgType MsgType

+ SrcSynerexId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GatewayMsg) ProtoMessage()

+ func (*GatewayMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *GatewayMsg) XXX_Merge(src proto.Message)

+ func (m *GatewayMsg) GetDemand() *Demand

+ func (m *GatewayMsg) GetMbus() *Mbus

+ func (m *GatewayMsg) GetMbusMsg() *MbusMsg

+ func (m *GatewayMsg) GetMsgOneof() isGatewayMsg_MsgOneof

+ func (m *GatewayMsg) GetMsgType() MsgType

+ func (m *GatewayMsg) GetSrcSynerexId() uint64

+ func (m *GatewayMsg) GetSupply() *Supply

+ func (m *GatewayMsg) GetTarget() *Target

+ func (m *GatewayMsg) Reset()

+ func (m *GatewayMsg) String() string

+ func (m *GatewayMsg) XXX_DiscardUnknown()

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

+ func (m *GatewayMsg) XXX_Size() int

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

+ type GatewayMsg_Demand struct

+ Demand *Demand

+ type GatewayMsg_Mbus struct

+ Mbus *Mbus

+ type GatewayMsg_MbusMsg struct

+ MbusMsg *MbusMsg

+ type GatewayMsg_Supply struct

+ Supply *Supply

+ type GatewayMsg_Target struct

+ Target *Target

+ type GatewayType int32

+ const GatewayType_BIDIRECTIONAL

+ const GatewayType_READ_ONLY

+ const GatewayType_WRITE_ONLY

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

+ func (x GatewayType) String() string

+ type MsgType int32

+ const MsgType_DEMAND

+ const MsgType_MBUS

+ const MsgType_MBUSMSG

+ const MsgType_SUPPLY

+ const MsgType_TARGET

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

+ func (x MsgType) String() string

type SynerexClient

+ ForwardToGateway func(ctx context.Context, in *GatewayMsg, opts ...grpc.CallOption) (*Response, error)

+ SubscribeGateway func(ctx context.Context, in *GatewayInfo, opts ...grpc.CallOption) (Synerex_SubscribeGatewayClient, error)

type SynerexServer

+ ForwardToGateway func(context.Context, *GatewayMsg) (*Response, error)

+ SubscribeGateway func(*GatewayInfo, Synerex_SubscribeGatewayServer) error

+ type Synerex_SubscribeGatewayClient interface

+ Recv func() (*GatewayMsg, error)

+ type Synerex_SubscribeGatewayServer interface

+ Send func(*GatewayMsg) error

v0.0.1

Sep 21, 2019

Changes in this version

+ func RegisterSynerexServer(s *grpc.Server, srv SynerexServer)

+ type Channel struct

+ ArgJson string

+ ChannelType uint32

+ ClientId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Channel) ProtoMessage()

+ func (dst *Channel) XXX_Merge(src proto.Message)

+ func (m *Channel) GetArgJson() string

+ func (m *Channel) GetChannelType() uint32

+ func (m *Channel) GetClientId() uint64

+ func (m *Channel) Reset()

+ func (m *Channel) String() string

+ func (m *Channel) XXX_DiscardUnknown()

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

+ func (m *Channel) XXX_Size() int

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

+ type ConfirmResponse struct

+ Err string

+ MbusId uint64

+ Ok bool

+ Wait *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConfirmResponse) ProtoMessage()

+ func (dst *ConfirmResponse) XXX_Merge(src proto.Message)

+ func (m *ConfirmResponse) GetErr() string

+ func (m *ConfirmResponse) GetMbusId() uint64

+ func (m *ConfirmResponse) GetOk() bool

+ func (m *ConfirmResponse) GetWait() *duration.Duration

+ func (m *ConfirmResponse) Reset()

+ func (m *ConfirmResponse) String() string

+ func (m *ConfirmResponse) XXX_DiscardUnknown()

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

+ func (m *ConfirmResponse) XXX_Size() int

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

+ type Content struct

+ Entity []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Content) ProtoMessage()

+ func (dst *Content) XXX_Merge(src proto.Message)

+ func (m *Content) GetEntity() []byte

+ func (m *Content) Reset()

+ func (m *Content) String() string

+ func (m *Content) XXX_DiscardUnknown()

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

+ func (m *Content) XXX_Size() int

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

+ type Demand struct

+ ArgJson string

+ Cdata *Content

+ ChannelType uint32

+ DemandName string

+ Id uint64

+ MbusId uint64

+ SenderId uint64

+ TargetId uint64

+ Ts *timestamp.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Demand) ProtoMessage()

+ func (dst *Demand) XXX_Merge(src proto.Message)

+ func (m *Demand) GetArgJson() string

+ func (m *Demand) GetCdata() *Content

+ func (m *Demand) GetChannelType() uint32

+ func (m *Demand) GetDemandName() string

+ func (m *Demand) GetId() uint64

+ func (m *Demand) GetMbusId() uint64

+ func (m *Demand) GetSenderId() uint64

+ func (m *Demand) GetTargetId() uint64

+ func (m *Demand) GetTs() *timestamp.Timestamp

+ func (m *Demand) Reset()

+ func (m *Demand) String() string

+ func (m *Demand) XXX_DiscardUnknown()

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

+ func (m *Demand) XXX_Size() int

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

+ type Mbus struct

+ ArgJson string

+ ClientId uint64

+ MbusId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Mbus) ProtoMessage()

+ func (dst *Mbus) XXX_Merge(src proto.Message)

+ func (m *Mbus) GetArgJson() string

+ func (m *Mbus) GetClientId() uint64

+ func (m *Mbus) GetMbusId() uint64

+ func (m *Mbus) Reset()

+ func (m *Mbus) String() string

+ func (m *Mbus) XXX_DiscardUnknown()

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

+ func (m *Mbus) XXX_Size() int

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

+ type MbusMsg struct

+ ArgJson string

+ MbusId uint64

+ MsgId uint64

+ MsgInfo string

+ MsgType uint32

+ SenderId uint64

+ TargetId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MbusMsg) ProtoMessage()

+ func (dst *MbusMsg) XXX_Merge(src proto.Message)

+ func (m *MbusMsg) GetArgJson() string

+ func (m *MbusMsg) GetMbusId() uint64

+ func (m *MbusMsg) GetMsgId() uint64

+ func (m *MbusMsg) GetMsgInfo() string

+ func (m *MbusMsg) GetMsgType() uint32

+ func (m *MbusMsg) GetSenderId() uint64

+ func (m *MbusMsg) GetTargetId() uint64

+ func (m *MbusMsg) Reset()

+ func (m *MbusMsg) String() string

+ func (m *MbusMsg) XXX_DiscardUnknown()

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

+ func (m *MbusMsg) XXX_Size() int

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

+ type Response struct

+ Err string

+ Ok bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Response) ProtoMessage()

+ func (dst *Response) XXX_Merge(src proto.Message)

+ func (m *Response) GetErr() string

+ func (m *Response) GetOk() bool

+ func (m *Response) Reset()

+ func (m *Response) String() string

+ func (m *Response) XXX_DiscardUnknown()

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

+ func (m *Response) XXX_Size() int

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

+ type Supply struct

+ ArgJson string

+ Cdata *Content

+ ChannelType uint32

+ Id uint64

+ MbusId uint64

+ SenderId uint64

+ SupplyName string

+ TargetId uint64

+ Ts *timestamp.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Supply) ProtoMessage()

+ func (dst *Supply) XXX_Merge(src proto.Message)

+ func (m *Supply) GetArgJson() string

+ func (m *Supply) GetCdata() *Content

+ func (m *Supply) GetChannelType() uint32

+ func (m *Supply) GetId() uint64

+ func (m *Supply) GetMbusId() uint64

+ func (m *Supply) GetSenderId() uint64

+ func (m *Supply) GetSupplyName() string

+ func (m *Supply) GetTargetId() uint64

+ func (m *Supply) GetTs() *timestamp.Timestamp

+ func (m *Supply) Reset()

+ func (m *Supply) String() string

+ func (m *Supply) XXX_DiscardUnknown()

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

+ func (m *Supply) XXX_Size() int

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

+ type SynerexClient interface

+ CloseMbus func(ctx context.Context, in *Mbus, opts ...grpc.CallOption) (*Response, error)

+ Confirm func(ctx context.Context, in *Target, opts ...grpc.CallOption) (*Response, error)

+ NotifyDemand func(ctx context.Context, in *Demand, opts ...grpc.CallOption) (*Response, error)

+ NotifySupply func(ctx context.Context, in *Supply, opts ...grpc.CallOption) (*Response, error)

+ ProposeDemand func(ctx context.Context, in *Demand, opts ...grpc.CallOption) (*Response, error)

+ ProposeSupply func(ctx context.Context, in *Supply, opts ...grpc.CallOption) (*Response, error)

+ SelectDemand func(ctx context.Context, in *Target, opts ...grpc.CallOption) (*ConfirmResponse, error)

+ SelectSupply func(ctx context.Context, in *Target, opts ...grpc.CallOption) (*ConfirmResponse, error)

+ SendMsg func(ctx context.Context, in *MbusMsg, opts ...grpc.CallOption) (*Response, error)

+ SubscribeDemand func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (Synerex_SubscribeDemandClient, error)

+ SubscribeMbus func(ctx context.Context, in *Mbus, opts ...grpc.CallOption) (Synerex_SubscribeMbusClient, error)

+ SubscribeSupply func(ctx context.Context, in *Channel, opts ...grpc.CallOption) (Synerex_SubscribeSupplyClient, error)

+ func NewSynerexClient(cc *grpc.ClientConn) SynerexClient

+ type SynerexServer interface

+ CloseMbus func(context.Context, *Mbus) (*Response, error)

+ Confirm func(context.Context, *Target) (*Response, error)

+ NotifyDemand func(context.Context, *Demand) (*Response, error)

+ NotifySupply func(context.Context, *Supply) (*Response, error)

+ ProposeDemand func(context.Context, *Demand) (*Response, error)

+ ProposeSupply func(context.Context, *Supply) (*Response, error)

+ SelectDemand func(context.Context, *Target) (*ConfirmResponse, error)

+ SelectSupply func(context.Context, *Target) (*ConfirmResponse, error)

+ SendMsg func(context.Context, *MbusMsg) (*Response, error)

+ SubscribeDemand func(*Channel, Synerex_SubscribeDemandServer) error

+ SubscribeMbus func(*Mbus, Synerex_SubscribeMbusServer) error

+ SubscribeSupply func(*Channel, Synerex_SubscribeSupplyServer) error

+ type Synerex_SubscribeDemandClient interface

+ Recv func() (*Demand, error)

+ type Synerex_SubscribeDemandServer interface

+ Send func(*Demand) error

+ type Synerex_SubscribeMbusClient interface

+ Recv func() (*MbusMsg, error)

+ type Synerex_SubscribeMbusServer interface

+ Send func(*MbusMsg) error

+ type Synerex_SubscribeSupplyClient interface

+ Recv func() (*Supply, error)

+ type Synerex_SubscribeSupplyServer interface

+ Send func(*Supply) error

+ type Target struct

+ ChannelType uint32

+ Id uint64

+ MbusId uint64

+ SenderId uint64

+ TargetId uint64

+ Wait *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Target) ProtoMessage()

+ func (dst *Target) XXX_Merge(src proto.Message)

+ func (m *Target) GetChannelType() uint32

+ func (m *Target) GetId() uint64

+ func (m *Target) GetMbusId() uint64

+ func (m *Target) GetSenderId() uint64

+ func (m *Target) GetTargetId() uint64

+ func (m *Target) GetWait() *duration.Duration

+ func (m *Target) Reset()

+ func (m *Target) String() string

+ func (m *Target) XXX_DiscardUnknown()

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

+ func (m *Target) XXX_Size() int

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

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