Documentation ¶
Index ¶
- func PipelineAddName(builder *flatbuffers.Builder, name flatbuffers.UOffsetT)
- func PipelineEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func PipelineStart(builder *flatbuffers.Builder)
- func QueueMessageAddPayload(builder *flatbuffers.Builder, payload flatbuffers.UOffsetT)
- func QueueMessageAddPipelines(builder *flatbuffers.Builder, pipelines flatbuffers.UOffsetT)
- func QueueMessageAddUniqueId(builder *flatbuffers.Builder, uniqueId flatbuffers.UOffsetT)
- func QueueMessageAddWebhookDestination(builder *flatbuffers.Builder, webhookDestination flatbuffers.UOffsetT)
- func QueueMessageEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func QueueMessageStart(builder *flatbuffers.Builder)
- func QueueMessageStartPayloadVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func QueueMessageStartPipelinesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func QueueMessageStartUniqueIdVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func WebhookAddHeaders(builder *flatbuffers.Builder, headers flatbuffers.UOffsetT)
- func WebhookAddMethod(builder *flatbuffers.Builder, method flatbuffers.UOffsetT)
- func WebhookAddQueryParams(builder *flatbuffers.Builder, queryParams flatbuffers.UOffsetT)
- func WebhookAddUrl(builder *flatbuffers.Builder, url flatbuffers.UOffsetT)
- func WebhookEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT
- func WebhookStart(builder *flatbuffers.Builder)
- func WebhookStartHeadersVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- func WebhookStartUrlVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT
- type Pipeline
- type QueueMessage
- func (rcv *QueueMessage) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *QueueMessage) MutatePayload(j int, n byte) bool
- func (rcv *QueueMessage) MutateUniqueId(j int, n byte) bool
- func (rcv *QueueMessage) Payload(j int) byte
- func (rcv *QueueMessage) PayloadBytes() []byte
- func (rcv *QueueMessage) PayloadLength() int
- func (rcv *QueueMessage) Pipelines(obj *Pipeline, j int) bool
- func (rcv *QueueMessage) PipelinesLength() int
- func (rcv *QueueMessage) Table() flatbuffers.Table
- func (rcv *QueueMessage) UniqueId(j int) byte
- func (rcv *QueueMessage) UniqueIdBytes() []byte
- func (rcv *QueueMessage) UniqueIdLength() int
- func (rcv *QueueMessage) WebhookDestination(obj *Webhook) *Webhook
- type Webhook
- func (rcv *Webhook) Headers(j int) byte
- func (rcv *Webhook) HeadersBytes() []byte
- func (rcv *Webhook) HeadersLength() int
- func (rcv *Webhook) Init(buf []byte, i flatbuffers.UOffsetT)
- func (rcv *Webhook) Method() []byte
- func (rcv *Webhook) MutateHeaders(j int, n byte) bool
- func (rcv *Webhook) MutateUrl(j int, n byte) bool
- func (rcv *Webhook) QueryParams() []byte
- func (rcv *Webhook) Table() flatbuffers.Table
- func (rcv *Webhook) Url(j int) byte
- func (rcv *Webhook) UrlBytes() []byte
- func (rcv *Webhook) UrlLength() int
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 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) 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 ¶
/ 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 (*Webhook) HeadersLength ¶
func (*Webhook) MutateHeaders ¶
/ 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 ¶
/ 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 ¶
/ 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 ¶
/ 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