tesla

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EnumNamesMessage = map[Message]string{
	MessageNONE:                 "NONE",
	MessageFlatbuffersStream:    "FlatbuffersStream",
	MessageFlatbuffersStreamAck: "FlatbuffersStreamAck",
}

Functions

func FlatbuffersEnvelopeAddMessage 

func FlatbuffersEnvelopeAddMessage(builder *flatbuffers.Builder, message flatbuffers.UOffsetT)

func FlatbuffersEnvelopeAddMessageId 

func FlatbuffersEnvelopeAddMessageId(builder *flatbuffers.Builder, messageId flatbuffers.UOffsetT)

func FlatbuffersEnvelopeAddMessageType 

func FlatbuffersEnvelopeAddMessageType(builder *flatbuffers.Builder, messageType byte)

func FlatbuffersEnvelopeAddTopic 

func FlatbuffersEnvelopeAddTopic(builder *flatbuffers.Builder, topic flatbuffers.UOffsetT)

func FlatbuffersEnvelopeAddTxid 

func FlatbuffersEnvelopeAddTxid(builder *flatbuffers.Builder, txid flatbuffers.UOffsetT)

func FlatbuffersEnvelopeEnd 

func FlatbuffersEnvelopeEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func FlatbuffersEnvelopeStart 

func FlatbuffersEnvelopeStart(builder *flatbuffers.Builder)

func FlatbuffersEnvelopeStartMessageIdVector 

func FlatbuffersEnvelopeStartMessageIdVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FlatbuffersEnvelopeStartTopicVector 

func FlatbuffersEnvelopeStartTopicVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FlatbuffersEnvelopeStartTxidVector 

func FlatbuffersEnvelopeStartTxidVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FlatbuffersEnvelopeToBytes 

func FlatbuffersEnvelopeToBytes(b *flatbuffers.Builder, txid, topic []byte, msg flatbuffers.UOffsetT, messageID []byte, msgType byte) []byte

FlatbuffersEnvelopeToBytes dump all the field of a FlatbuffersCommand into a flatbuffers []byte

func FlatbuffersStreamAckEnd 

func FlatbuffersStreamAckEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func FlatbuffersStreamAckStart 

func FlatbuffersStreamAckStart(builder *flatbuffers.Builder)

func FlatbuffersStreamAckToBytes 

func FlatbuffersStreamAckToBytes(txid, topic, messageID []byte) []byte

FlatbuffersStreamAckToBytes dump all the field of a FlatbuffersStream into a flatbuffers []byte

func FlatbuffersStreamAddCreatedAt 

func FlatbuffersStreamAddCreatedAt(builder *flatbuffers.Builder, createdAt uint32)

func FlatbuffersStreamAddDeliveredAtEpochMs 

func FlatbuffersStreamAddDeliveredAtEpochMs(builder *flatbuffers.Builder, DeliveredAtEpochMs uint64)

func FlatbuffersStreamAddDeviceId 

func FlatbuffersStreamAddDeviceId(builder *flatbuffers.Builder, deviceId flatbuffers.UOffsetT)

func FlatbuffersStreamAddDeviceType 

func FlatbuffersStreamAddDeviceType(builder *flatbuffers.Builder, deviceType flatbuffers.UOffsetT)

func FlatbuffersStreamAddPayload 

func FlatbuffersStreamAddPayload(builder *flatbuffers.Builder, payload flatbuffers.UOffsetT)

func FlatbuffersStreamAddSenderId 

func FlatbuffersStreamAddSenderId(builder *flatbuffers.Builder, senderId flatbuffers.UOffsetT)

func FlatbuffersStreamEnd 

func FlatbuffersStreamEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func FlatbuffersStreamStart 

func FlatbuffersStreamStart(builder *flatbuffers.Builder)

func FlatbuffersStreamStartDeviceIdVector 

func FlatbuffersStreamStartDeviceIdVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FlatbuffersStreamStartDeviceTypeVector 

func FlatbuffersStreamStartDeviceTypeVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FlatbuffersStreamStartPayloadVector 

func FlatbuffersStreamStartPayloadVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FlatbuffersStreamStartSenderIdVector 

func FlatbuffersStreamStartSenderIdVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func FlatbuffersStreamToBytes 

func FlatbuffersStreamToBytes(senderID, topic, txid, payload []byte, createdAt uint32, messageID, deviceType, deviceID []byte, DeliveredAtEpochMs uint64) []byte

FlatbuffersStreamToBytes dump all the field of a FlatbuffersStream into a flatbuffers []byte

Types

type FlatbuffersEnvelope 

type FlatbuffersEnvelope struct {
	// contains filtered or unexported fields
}

func FlatbuffersEnvelopeFromBytes 

func FlatbuffersEnvelopeFromBytes(value []byte) (*FlatbuffersEnvelope, *flatbuffers.Table, error)

FlatbuffersEnvelopeFromBytes serializes a Flatbuffers Envelope from a slice of bytes

func GetRootAsFlatbuffersEnvelope 

func GetRootAsFlatbuffersEnvelope(buf []byte, offset flatbuffers.UOffsetT) *FlatbuffersEnvelope

func (*FlatbuffersEnvelope) Init 

func (rcv *FlatbuffersEnvelope) Init(buf []byte, i flatbuffers.UOffsetT)

func (*FlatbuffersEnvelope) Message 

func (rcv *FlatbuffersEnvelope) Message(obj *flatbuffers.Table) bool

func (*FlatbuffersEnvelope) MessageId 

func (rcv *FlatbuffersEnvelope) MessageId(j int) byte

func (*FlatbuffersEnvelope) MessageIdBytes 

func (rcv *FlatbuffersEnvelope) MessageIdBytes() []byte

func (*FlatbuffersEnvelope) MessageIdLength 

func (rcv *FlatbuffersEnvelope) MessageIdLength() int

func (*FlatbuffersEnvelope) MessageType 

func (rcv *FlatbuffersEnvelope) MessageType() byte

func (*FlatbuffersEnvelope) MutateMessageId 

func (rcv *FlatbuffersEnvelope) MutateMessageId(j int, n byte) bool

func (*FlatbuffersEnvelope) MutateMessageType 

func (rcv *FlatbuffersEnvelope) MutateMessageType(n byte) bool

func (*FlatbuffersEnvelope) MutateTopic 

func (rcv *FlatbuffersEnvelope) MutateTopic(j int, n byte) bool

topic: used for rooting messages to backend queues

func (*FlatbuffersEnvelope) MutateTxid 

func (rcv *FlatbuffersEnvelope) MutateTxid(j int, n byte) bool

txid: unique transaction id of this message

func (*FlatbuffersEnvelope) Table 

func (rcv *FlatbuffersEnvelope) Table() flatbuffers.Table

func (*FlatbuffersEnvelope) Topic 

func (rcv *FlatbuffersEnvelope) Topic(j int) byte

topic: used for rooting messages to backend queues

func (*FlatbuffersEnvelope) TopicBytes 

func (rcv *FlatbuffersEnvelope) TopicBytes() []byte

func (*FlatbuffersEnvelope) TopicLength 

func (rcv *FlatbuffersEnvelope) TopicLength() int

func (*FlatbuffersEnvelope) Txid 

func (rcv *FlatbuffersEnvelope) Txid(j int) byte

txid: unique transaction id of this message

func (*FlatbuffersEnvelope) TxidBytes 

func (rcv *FlatbuffersEnvelope) TxidBytes() []byte

func (*FlatbuffersEnvelope) TxidLength 

func (rcv *FlatbuffersEnvelope) TxidLength() int

type FlatbuffersStream 

type FlatbuffersStream struct {
	// contains filtered or unexported fields
}

func GetRootAsFlatbuffersStream 

func GetRootAsFlatbuffersStream(buf []byte, offset flatbuffers.UOffsetT) *FlatbuffersStream

func NewFlatbuffersStream 

func NewFlatbuffersStream(buf []byte, offset flatbuffers.UOffsetT) *FlatbuffersStream

NewFlatbuffersStream instantiate a new FlatbuffersStream according to its definition

func (*FlatbuffersStream) CreatedAt 

func (rcv *FlatbuffersStream) CreatedAt() uint32

func (*FlatbuffersStream) DeliveredAtEpochMs 

func (rcv *FlatbuffersStream) DeliveredAtEpochMs() uint64

delivered_at_epoch_ms: timestamp (in milliseconds) at which the message reached the backend

func (*FlatbuffersStream) DeviceId 

func (rcv *FlatbuffersStream) DeviceId(j int) byte

device_id: device identity coming from the certificate derived of Subject CN

func (*FlatbuffersStream) DeviceIdBytes 

func (rcv *FlatbuffersStream) DeviceIdBytes() []byte

func (*FlatbuffersStream) DeviceIdLength 

func (rcv *FlatbuffersStream) DeviceIdLength() int

func (*FlatbuffersStream) DeviceType 

func (rcv *FlatbuffersStream) DeviceType(j int) byte

device_type: device identity coming from the certificate derived of Issuer CN

func (*FlatbuffersStream) DeviceTypeBytes 

func (rcv *FlatbuffersStream) DeviceTypeBytes() []byte

func (*FlatbuffersStream) DeviceTypeLength 

func (rcv *FlatbuffersStream) DeviceTypeLength() int

func (*FlatbuffersStream) Init 

func (rcv *FlatbuffersStream) Init(buf []byte, i flatbuffers.UOffsetT)

func (*FlatbuffersStream) MutateCreatedAt 

func (rcv *FlatbuffersStream) MutateCreatedAt(n uint32) bool

func (*FlatbuffersStream) MutateDeliveredAtEpochMs 

func (rcv *FlatbuffersStream) MutateDeliveredAtEpochMs(n uint64) bool

delivered_at_epoch_ms: timestamp (in milliseconds) at which the message reached the backend

func (*FlatbuffersStream) MutateDeviceId 

func (rcv *FlatbuffersStream) MutateDeviceId(j int, n byte) bool

device_id: device identity coming from the certificate derived of Subject CN

func (*FlatbuffersStream) MutateDeviceType 

func (rcv *FlatbuffersStream) MutateDeviceType(j int, n byte) bool

device_type: device identity coming from the certificate derived of Issuer CN

func (*FlatbuffersStream) MutatePayload 

func (rcv *FlatbuffersStream) MutatePayload(j int, n byte) bool

func (*FlatbuffersStream) MutateSenderId 

func (rcv *FlatbuffersStream) MutateSenderId(j int, n byte) bool

sender_id: device identity coming from the certificate - DEPRECATED: use combination of device_type + device_id

func (*FlatbuffersStream) Payload 

func (rcv *FlatbuffersStream) Payload(j int) byte

func (*FlatbuffersStream) PayloadBytes 

func (rcv *FlatbuffersStream) PayloadBytes() []byte

func (*FlatbuffersStream) PayloadLength 

func (rcv *FlatbuffersStream) PayloadLength() int

func (*FlatbuffersStream) SenderId 

func (rcv *FlatbuffersStream) SenderId(j int) byte

sender_id: device identity coming from the certificate - DEPRECATED: use combination of device_type + device_id

func (*FlatbuffersStream) SenderIdBytes 

func (rcv *FlatbuffersStream) SenderIdBytes() []byte

func (*FlatbuffersStream) SenderIdLength 

func (rcv *FlatbuffersStream) SenderIdLength() int

func (*FlatbuffersStream) Table 

func (rcv *FlatbuffersStream) Table() flatbuffers.Table

func (*FlatbuffersStream) ToBytes 

func (fsm *FlatbuffersStream) ToBytes(envelope *FlatbuffersEnvelope) []byte

ToBytes dump all the field of a FlatbuffersCommand into a flatbuffers []byte

type FlatbuffersStreamAck 

type FlatbuffersStreamAck struct {
	// contains filtered or unexported fields
}

func GetRootAsFlatbuffersStreamAck 

func GetRootAsFlatbuffersStreamAck(buf []byte, offset flatbuffers.UOffsetT) *FlatbuffersStreamAck

func NewFlatbuffersStreamAck 

func NewFlatbuffersStreamAck(buf []byte, offset flatbuffers.UOffsetT) *FlatbuffersStreamAck

NewFlatbuffersStreamAck instantiate a new FlatbuffersStream according to its definition

func (*FlatbuffersStreamAck) Init 

func (rcv *FlatbuffersStreamAck) Init(buf []byte, i flatbuffers.UOffsetT)

func (*FlatbuffersStreamAck) Table 

func (rcv *FlatbuffersStreamAck) Table() flatbuffers.Table

type Message 

type Message = byte
const (
	MessageNONE                 Message = 0
	MessageFlatbuffersStream    Message = 4
	MessageFlatbuffersStreamAck Message = 5
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.