fb

Documentation

Index

• func FlakiReplyAddId(builder *flatbuffers.Builder, id flatbuffers.UOffsetT)
• func FlakiReplyEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func FlakiReplyStart(builder *flatbuffers.Builder)
• func FlakiRequestEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
• func FlakiRequestStart(builder *flatbuffers.Builder)
• func RegisterFlakiServer(s *grpc.Server, srv FlakiServer)
• type FlakiClient
  • func NewFlakiClient(cc *grpc.ClientConn) FlakiClient
• type FlakiReply
  • func GetRootAsFlakiReply(buf []byte, offset flatbuffers.UOffsetT) *FlakiReply
  • func (rcv *FlakiReply) Id() []byte
  • func (rcv *FlakiReply) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *FlakiReply) Table() flatbuffers.Table
• type FlakiRequest
  • func GetRootAsFlakiRequest(buf []byte, offset flatbuffers.UOffsetT) *FlakiRequest
  • func (rcv *FlakiRequest) Init(buf []byte, i flatbuffers.UOffsetT)
  • func (rcv *FlakiRequest) Table() flatbuffers.Table
• type FlakiServer

Functions

func FlakiReplyAddId

func FlakiReplyAddId(builder *flatbuffers.Builder, id flatbuffers.UOffsetT)

func FlakiReplyEnd

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

func FlakiReplyStart

func FlakiReplyStart(builder *flatbuffers.Builder)

func FlakiRequestEnd

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

func FlakiRequestStart

func FlakiRequestStart(builder *flatbuffers.Builder)

func RegisterFlakiServer

func RegisterFlakiServer(s *grpc.Server, srv FlakiServer)

Types

type FlakiClient

type FlakiClient interface {
	NextID(ctx context.Context, in *flatbuffers.Builder,
		opts ...grpc.CallOption) (*FlakiReply, error)
	NextValidID(ctx context.Context, in *flatbuffers.Builder,
		opts ...grpc.CallOption) (*FlakiReply, error)
}

Client API for Flaki service

func NewFlakiClient

func NewFlakiClient(cc *grpc.ClientConn) FlakiClient

type FlakiReply

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

func GetRootAsFlakiReply

func GetRootAsFlakiReply(buf []byte, offset flatbuffers.UOffsetT) *FlakiReply

func (*FlakiReply) Id

func (rcv *FlakiReply) Id() []byte

func (*FlakiReply) Init

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

func (*FlakiReply) Table

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

type FlakiRequest

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

func GetRootAsFlakiRequest

func GetRootAsFlakiRequest(buf []byte, offset flatbuffers.UOffsetT) *FlakiRequest

func (*FlakiRequest) Init

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

func (*FlakiRequest) Table

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

type FlakiServer

type FlakiServer interface {
	NextID(context.Context, *FlakiRequest) (*flatbuffers.Builder, error)
	NextValidID(context.Context, *FlakiRequest) (*flatbuffers.Builder, error)
}

Server API for Flaki service