flatbuf

package
v0.0.0-...-446cd28 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2021 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PipelineAddName 

func PipelineAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)

func PipelineEnd 

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

func PipelineStart 

func PipelineStart(builder *flatbuffers.Builder)

/ The name of the pipeline.

func QueueMessageAddPayload 

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

func QueueMessageAddPipelines 

func QueueMessageAddPipelines(builder *flatbuffers.Builder, pipelines flatbuffers.UOffsetT)

func QueueMessageAddUniqueId 

func QueueMessageAddUniqueId(builder *flatbuffers.Builder, uniqueId flatbuffers.UOffsetT)

func QueueMessageAddWebhookDestination 

func QueueMessageAddWebhookDestination(builder *flatbuffers.Builder, webhookDestination flatbuffers.UOffsetT)

func QueueMessageEnd 

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

func QueueMessageStart 

func QueueMessageStart(builder *flatbuffers.Builder)

/ The destination where the payload will be sent.

func QueueMessageStartPayloadVector 

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

func QueueMessageStartPipelinesVector 

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

func QueueMessageStartUniqueIdVector 

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

func WebhookAddHeaders 

func WebhookAddHeaders(builder *flatbuffers.Builder, headers flatbuffers.UOffsetT)

func WebhookAddMethod 

func WebhookAddMethod(builder *flatbuffers.Builder, method flatbuffers.UOffsetT)

func WebhookAddQueryParams 

func WebhookAddQueryParams(builder *flatbuffers.Builder, queryParams flatbuffers.UOffsetT)

func WebhookAddUrl 

func WebhookAddUrl(builder *flatbuffers.Builder, url flatbuffers.UOffsetT)

func WebhookEnd 

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

func WebhookStart 

func WebhookStart(builder *flatbuffers.Builder)

func WebhookStartHeadersVector 

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

func WebhookStartUrlVector 

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

Types

type Pipeline 

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

func GetRootAsPipeline 

func GetRootAsPipeline(buf []byte, offset flatbuffers.UOffsetT) *Pipeline

func (*Pipeline) Init 

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

func (*Pipeline) Name 

func (rcv *Pipeline) Name() []byte

/ The name of the pipeline.

func (*Pipeline) Table 

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

type QueueMessage 

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

/ The format for serializing a queue message.

func GetRootAsQueueMessage 

func GetRootAsQueueMessage(buf []byte, offset flatbuffers.UOffsetT) *QueueMessage

func (*QueueMessage) Init 

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

func (*QueueMessage) MutatePayload 

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

/ The API caller's payload of the message.

func (*QueueMessage) MutateUniqueId 

func (rcv *QueueMessage) MutateUniqueId(j int, n byte) bool

/ The unique identifier generated by the client API.

func (*QueueMessage) Payload 

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

/ The pipelines to process. / The API caller's payload of the message.

func (*QueueMessage) PayloadBytes 

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

func (*QueueMessage) PayloadLength 

func (rcv *QueueMessage) PayloadLength() int

func (*QueueMessage) Pipelines 

func (rcv *QueueMessage) Pipelines(obj *Pipeline, j int) bool

/ The pipelines to process.

func (*QueueMessage) PipelinesLength 

func (rcv *QueueMessage) PipelinesLength() int

func (*QueueMessage) Table 

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

func (*QueueMessage) UniqueId 

func (rcv *QueueMessage) UniqueId(j int) byte

/ The unique identifier generated by the client API.

func (*QueueMessage) UniqueIdBytes 

func (rcv *QueueMessage) UniqueIdBytes() []byte

func (*QueueMessage) UniqueIdLength 

func (rcv *QueueMessage) UniqueIdLength() int

func (*QueueMessage) WebhookDestination 

func (rcv *QueueMessage) WebhookDestination(obj *Webhook) *Webhook

/ The destination where the payload will be sent.

type Webhook 

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

func GetRootAsWebhook 

func GetRootAsWebhook(buf []byte, offset flatbuffers.UOffsetT) *Webhook

func (*Webhook) Headers 

func (rcv *Webhook) Headers(j int) byte

/ The http request Method, i.e. GET, POST. / Headers to be set in the http request. / To understand how this is serialized, see: / - https://golang.org/pkg/net/http/#Header.Write / - https://golang.org/pkg/net/textproto/#Reader.ReadMIMEHeader

func (*Webhook) HeadersBytes 

func (rcv *Webhook) HeadersBytes() []byte

func (*Webhook) HeadersLength 

func (rcv *Webhook) HeadersLength() int

func (*Webhook) Init 

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

func (*Webhook) Method 

func (rcv *Webhook) Method() []byte

/ The http request Method, i.e. GET, POST.

func (*Webhook) MutateHeaders 

func (rcv *Webhook) MutateHeaders(j int, n byte) bool

/ Headers to be set in the http request. / To understand how this is serialized, see: / - https://golang.org/pkg/net/http/#Header.Write / - https://golang.org/pkg/net/textproto/#Reader.ReadMIMEHeader

func (*Webhook) MutateUrl 

func (rcv *Webhook) MutateUrl(j int, n byte) bool

/ URL to send the request to. You may include query parameters in the Url. / The QueryParams specified seperately will be appended to this Url before / making the request. / / This is marshaled and unmarshaled using MarshalBinary and UnmarshalBinary. / - https://golang.org/pkg/net/url/#Values / - https://golang.org/pkg/net/url/#ParseRequestURI / - https://golang.org/pkg/net/url/#URL.MarshalBinary / - https://golang.org/pkg/net/url/#URL.UnmarshalBinary

func (*Webhook) QueryParams 

func (rcv *Webhook) QueryParams() []byte

/ URL encoded query paramaters to be set in the http request. / This is marshaled and unmarshaled using Encode and ParseQuery. / - https://golang.org/pkg/net/url/#Values.Encode / - https://golang.org/pkg/net/url/#ParseQuery

func (*Webhook) Table 

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

func (*Webhook) Url 

func (rcv *Webhook) Url(j int) byte

/ URL encoded query paramaters to be set in the http request. / This is marshaled and unmarshaled using Encode and ParseQuery. / - https://golang.org/pkg/net/url/#Values.Encode / - https://golang.org/pkg/net/url/#ParseQuery / URL to send the request to. You may include query parameters in the Url. / The QueryParams specified seperately will be appended to this Url before / making the request. / / This is marshaled and unmarshaled using MarshalBinary and UnmarshalBinary. / - https://golang.org/pkg/net/url/#Values / - https://golang.org/pkg/net/url/#ParseRequestURI / - https://golang.org/pkg/net/url/#URL.MarshalBinary / - https://golang.org/pkg/net/url/#URL.UnmarshalBinary

func (*Webhook) UrlBytes 

func (rcv *Webhook) UrlBytes() []byte

func (*Webhook) UrlLength 

func (rcv *Webhook) UrlLength() int

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.