datastreamer

Documentation

Index

• func GetIntCounter(l *log.Logger) chan int
• func NewGobStreamer(netstring string, data interface{}, ctrl <-chan bool, counter chan int)
• func NewProtoBStreamer(netstring string, data proto.Message, ctrl <-chan bool, counter chan int) chan bool
• type Content
  • func (*Content) Descriptor() ([]byte, []int)
  • func (m *Content) GetChannel() int64
  • func (m *Content) GetCtp() int64
  • func (m *Content) GetFe() int64
  • func (m *Content) GetGate() []*Gatesignal
  • func (*Content) ProtoMessage()
  • 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_Merge(src proto.Message)
  • func (m *Content) XXX_Size() int
  • func (m *Content) XXX_Unmarshal(b []byte) error
• type Gatesignal
  • func (*Gatesignal) Descriptor() ([]byte, []int)
  • func (m *Gatesignal) GetAmp() int64
  • func (m *Gatesignal) GetGateATof() int64
  • func (m *Gatesignal) GetGateBTof() int64
  • func (*Gatesignal) ProtoMessage()
  • func (m *Gatesignal) Reset()
  • func (m *Gatesignal) String() string
  • func (m *Gatesignal) XXX_DiscardUnknown()
  • func (m *Gatesignal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Gatesignal) XXX_Merge(src proto.Message)
  • func (m *Gatesignal) XXX_Size() int
  • func (m *Gatesignal) XXX_Unmarshal(b []byte) error

Functions

func GetIntCounter

func GetIntCounter(l *log.Logger) chan int

func NewGobStreamer

func NewGobStreamer(netstring string, data interface{}, ctrl <-chan bool, counter chan int)

func NewProtoBStreamer

func NewProtoBStreamer(netstring string, data proto.Message, ctrl <-chan bool, counter chan int) chan bool

Types

type Content

type Content struct {
	Fe                   int64         `protobuf:"varint,1,opt,name=fe,proto3" json:"fe,omitempty"`
	Ctp                  int64         `protobuf:"varint,2,opt,name=ctp,proto3" json:"ctp,omitempty"`
	Channel              int64         `protobuf:"varint,3,opt,name=channel,proto3" json:"channel,omitempty"`
	Gate                 []*Gatesignal `protobuf:"bytes,4,rep,name=gate,proto3" json:"gate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Content) Descriptor

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

func (*Content) GetChannel

func (m *Content) GetChannel() int64

func (*Content) GetCtp

func (m *Content) GetCtp() int64

func (*Content) GetFe

func (m *Content) GetFe() int64

func (*Content) GetGate

func (m *Content) GetGate() []*Gatesignal

func (*Content) ProtoMessage

func (*Content) ProtoMessage()

func (*Content) Reset

func (m *Content) Reset()

func (*Content) String

func (m *Content) String() string

func (*Content) XXX_DiscardUnknown

func (m *Content) XXX_DiscardUnknown()

func (*Content) XXX_Marshal

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

func (*Content) XXX_Merge

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

func (*Content) XXX_Size

func (m *Content) XXX_Size() int

func (*Content) XXX_Unmarshal

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

type Gatesignal

type Gatesignal struct {
	GateATof             int64    `protobuf:"varint,1,opt,name=GateATof,proto3" json:"GateATof,omitempty"`
	GateBTof             int64    `protobuf:"varint,2,opt,name=GateBTof,proto3" json:"GateBTof,omitempty"`
	Amp                  int64    `protobuf:"varint,3,opt,name=Amp,proto3" json:"Amp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Gatesignal) Descriptor

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

func (*Gatesignal) GetAmp

func (m *Gatesignal) GetAmp() int64

func (*Gatesignal) GetGateATof

func (m *Gatesignal) GetGateATof() int64

func (*Gatesignal) GetGateBTof

func (m *Gatesignal) GetGateBTof() int64

func (*Gatesignal) ProtoMessage

func (*Gatesignal) ProtoMessage()

func (*Gatesignal) Reset

func (m *Gatesignal) Reset()

func (*Gatesignal) String

func (m *Gatesignal) String() string

func (*Gatesignal) XXX_DiscardUnknown

func (m *Gatesignal) XXX_DiscardUnknown()

func (*Gatesignal) XXX_Marshal

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

func (*Gatesignal) XXX_Merge

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

func (*Gatesignal) XXX_Size

func (m *Gatesignal) XXX_Size() int

func (*Gatesignal) XXX_Unmarshal

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