core

package
v0.0.0-...-e6efe32 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2021 License: ISC Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EnumNamesReader = map[Reader]string{
	ReaderNONE:   "NONE",
	ReaderStream: "Stream",
	ReaderFile:   "File",
}
View Source 
var EnumValuesReader = map[string]Reader{
	"NONE":   ReaderNONE,
	"Stream": ReaderStream,
	"File":   ReaderFile,
}

Functions

func CreateObject 

func CreateObject(builder *flatbuffers.Builder, objectId uint64) flatbuffers.UOffsetT

func ErrorAddError 

func ErrorAddError(builder *flatbuffers.Builder, error flatbuffers.UOffsetT)

func ErrorEnd 

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

func ErrorStart 

func ErrorStart(builder *flatbuffers.Builder)

func FileAddFilepath 

func FileAddFilepath(builder *flatbuffers.Builder, filepath flatbuffers.UOffsetT)

func FileEnd 

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

func FileStart 

func FileStart(builder *flatbuffers.Builder)

func RegisterStreamerServer 

func RegisterStreamerServer(s *grpc.Server, srv StreamerServer)

func StreamAddBufferSize 

func StreamAddBufferSize(builder *flatbuffers.Builder, bufferSize int64)

func StreamAddTicket 

func StreamAddTicket(builder *flatbuffers.Builder, ticket flatbuffers.UOffsetT)

func StreamDataAddBytes 

func StreamDataAddBytes(builder *flatbuffers.Builder, bytes flatbuffers.UOffsetT)

func StreamDataAddError 

func StreamDataAddError(builder *flatbuffers.Builder, error flatbuffers.UOffsetT)

func StreamDataAddTicketId 

func StreamDataAddTicketId(builder *flatbuffers.Builder, ticketId uint64)

func StreamDataEnd 

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

func StreamDataStart 

func StreamDataStart(builder *flatbuffers.Builder)

func StreamDataStartBytesVector 

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

func StreamEnd 

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

func StreamStart 

func StreamStart(builder *flatbuffers.Builder)

func StreamTicketAddTicketId 

func StreamTicketAddTicketId(builder *flatbuffers.Builder, ticketId uint64)

func StreamTicketEnd 

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

func StreamTicketStart 

func StreamTicketStart(builder *flatbuffers.Builder)

func StringPairAddK 

func StringPairAddK(builder *flatbuffers.Builder, k flatbuffers.UOffsetT)

func StringPairAddV 

func StringPairAddV(builder *flatbuffers.Builder, v flatbuffers.UOffsetT)

func StringPairEnd 

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

func StringPairStart 

func StringPairStart(builder *flatbuffers.Builder)

func TimeAddUnixNano 

func TimeAddUnixNano(builder *flatbuffers.Builder, unixNano int64)

func TimeEnd 

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

func TimeStart 

func TimeStart(builder *flatbuffers.Builder)

Types

type Error 

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

func GetRootAsError 

func GetRootAsError(buf []byte, offset flatbuffers.UOffsetT) *Error

func GetSizePrefixedRootAsError 

func GetSizePrefixedRootAsError(buf []byte, offset flatbuffers.UOffsetT) *Error

func (*Error) Error 

func (rcv *Error) Error() []byte

func (*Error) Init 

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

func (*Error) Table 

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

type File 

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

func GetRootAsFile 

func GetRootAsFile(buf []byte, offset flatbuffers.UOffsetT) *File

func GetSizePrefixedRootAsFile 

func GetSizePrefixedRootAsFile(buf []byte, offset flatbuffers.UOffsetT) *File

func (*File) Filepath 

func (rcv *File) Filepath() []byte

func (*File) Init 

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

func (*File) Table 

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

type Object 

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

func (*Object) Init 

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

func (*Object) MutateObjectId 

func (rcv *Object) MutateObjectId(n uint64) bool

func (*Object) ObjectId 

func (rcv *Object) ObjectId() uint64

func (*Object) Table 

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

type Reader 

type Reader byte
const (
	ReaderNONE   Reader = 0
	ReaderStream Reader = 1
	ReaderFile   Reader = 2
)

func (Reader) String 

func (v Reader) String() string

type Stream 

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

func GetRootAsStream 

func GetRootAsStream(buf []byte, offset flatbuffers.UOffsetT) *Stream

func GetSizePrefixedRootAsStream 

func GetSizePrefixedRootAsStream(buf []byte, offset flatbuffers.UOffsetT) *Stream

func (*Stream) BufferSize 

func (rcv *Stream) BufferSize() int64

func (*Stream) Init 

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

func (*Stream) MutateBufferSize 

func (rcv *Stream) MutateBufferSize(n int64) bool

func (*Stream) Table 

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

func (*Stream) Ticket 

func (rcv *Stream) Ticket(obj *StreamTicket) *StreamTicket

type StreamData 

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

func GetRootAsStreamData 

func GetRootAsStreamData(buf []byte, offset flatbuffers.UOffsetT) *StreamData

func GetSizePrefixedRootAsStreamData 

func GetSizePrefixedRootAsStreamData(buf []byte, offset flatbuffers.UOffsetT) *StreamData

func (*StreamData) Bytes 

func (rcv *StreamData) Bytes(j int) byte

func (*StreamData) BytesBytes 

func (rcv *StreamData) BytesBytes() []byte

func (*StreamData) BytesLength 

func (rcv *StreamData) BytesLength() int

func (*StreamData) Error 

func (rcv *StreamData) Error(obj *Error) *Error

func (*StreamData) Init 

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

func (*StreamData) MutateBytes 

func (rcv *StreamData) MutateBytes(j int, n byte) bool

func (*StreamData) MutateTicketId 

func (rcv *StreamData) MutateTicketId(n uint64) bool

func (*StreamData) Table 

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

func (*StreamData) TicketId 

func (rcv *StreamData) TicketId() uint64

type StreamTicket 

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

func GetRootAsStreamTicket 

func GetRootAsStreamTicket(buf []byte, offset flatbuffers.UOffsetT) *StreamTicket

func GetSizePrefixedRootAsStreamTicket 

func GetSizePrefixedRootAsStreamTicket(buf []byte, offset flatbuffers.UOffsetT) *StreamTicket

func (*StreamTicket) Init 

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

func (*StreamTicket) MutateTicketId 

func (rcv *StreamTicket) MutateTicketId(n uint64) bool

func (*StreamTicket) Table 

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

func (*StreamTicket) TicketId 

func (rcv *StreamTicket) TicketId() uint64

type StreamerClient 

type StreamerClient interface {
	Begin(ctx context.Context, in *flatbuffers.Builder,
		opts ...grpc.CallOption) (*Error, error)
	Stop(ctx context.Context, in *flatbuffers.Builder,
		opts ...grpc.CallOption) (*Error, error)
}

Client API for Streamer service

func NewStreamerClient 

func NewStreamerClient(cc *grpc.ClientConn) StreamerClient

type StreamerServer 

type StreamerServer interface {
	Begin(context.Context, *StreamTicket) (*flatbuffers.Builder, error)
	Stop(context.Context, *StreamTicket) (*flatbuffers.Builder, error)
}

Server API for Streamer service

type StringPair 

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

func GetRootAsStringPair 

func GetRootAsStringPair(buf []byte, offset flatbuffers.UOffsetT) *StringPair

func GetSizePrefixedRootAsStringPair 

func GetSizePrefixedRootAsStringPair(buf []byte, offset flatbuffers.UOffsetT) *StringPair

func (*StringPair) Init 

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

func (*StringPair) K 

func (rcv *StringPair) K() []byte

func (*StringPair) Table 

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

func (*StringPair) V 

func (rcv *StringPair) V() []byte

type Time 

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

func GetRootAsTime 

func GetRootAsTime(buf []byte, offset flatbuffers.UOffsetT) *Time

func GetSizePrefixedRootAsTime 

func GetSizePrefixedRootAsTime(buf []byte, offset flatbuffers.UOffsetT) *Time

func (*Time) Init 

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

func (*Time) MutateUnixNano 

func (rcv *Time) MutateUnixNano(n int64) bool

func (*Time) Table 

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

func (*Time) UnixNano 

func (rcv *Time) UnixNano() int64

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.