protocol

Documentation

Index

• type Pipeline
  • func (q *Pipeline) Bytes() []byte
  • func (q *Pipeline) MarshalBinary() ([]byte, error)
  • func (q *Pipeline) UnmarshalBinary(data []byte) error
• type QueueMessage
  • func QueueMessageFromNATS(msg *nats.Msg) QueueMessage
  • func (i *QueueMessage) Bytes() []byte
  • func (i *QueueMessage) MarshalBinary() ([]byte, error)
  • func (i *QueueMessage) NewReader() io.Reader
  • func (i *QueueMessage) UnmarshalBinary(data []byte) error
• type QueueMessageDestinationHttpRequest
  • func (r *QueueMessageDestinationHttpRequest) Bytes() []byte
  • func (r *QueueMessageDestinationHttpRequest) MarshalBinary() ([]byte, error)
  • func (r *QueueMessageDestinationHttpRequest) MarshalHeaders(headers http.Header) ([]byte, error)
  • func (r *QueueMessageDestinationHttpRequest) MarshalQueryParams(v url.Values) ([]byte, error)
  • func (r *QueueMessageDestinationHttpRequest) MarshalUrl(u url.URL) ([]byte, error)
  • func (r *QueueMessageDestinationHttpRequest) SetHeaders(headers http.Header) error
  • func (r *QueueMessageDestinationHttpRequest) SetQueryParams(v url.Values) error
  • func (r *QueueMessageDestinationHttpRequest) SetUrl(u url.URL) error
  • func (r *QueueMessageDestinationHttpRequest) UnmarshalBinary(data []byte) error
  • func (r *QueueMessageDestinationHttpRequest) UnmarshalHeaders() (http.Header, error)
  • func (r *QueueMessageDestinationHttpRequest) UnmarshalQueryParams() (url.Values, error)
  • func (r *QueueMessageDestinationHttpRequest) UnmarshalUrl() (url.URL, error)

Types

type Pipeline

type Pipeline struct {
	// The name of the pipeline.
	Name string
}

func (*Pipeline) Bytes

func (q *Pipeline) Bytes() []byte

func (*Pipeline) MarshalBinary

func (q *Pipeline) MarshalBinary() ([]byte, error)

func (*Pipeline) UnmarshalBinary

func (q *Pipeline) UnmarshalBinary(data []byte) error

type QueueMessage

type QueueMessage struct {
	// UniqueId is a unique id to identify this message. It may be used for
	// de-duplication by the stream processing.
	UniqueId ksuid.KSUID

	// Pipelines are the named pipelines to place the message on. You can think
	// of a pipeline as a series of unordered named queues.
	//
	// If there are multiple Pipelines set, then the message will be pushed
	// to each one. Pushing to Pipelines is atomic from the client, but not
	// guaranteed by the hyperscalr ingress plane. Hyperscalr ingress place will
	// attempt to push to the configured Pipelines optimistically on it's
	// end. This is the same as if multiple calls by the client were made to
	// single Pipelines.
	Pipelines []Pipeline

	// Payload message body of what you want pushed into the queue.
	//
	// It does have restrictions on size. The server is likely to reject
	// QueueMessage with total size greater than 32 KB.
	Payload []byte

	// The destination where the payload will be sent.
	DestinationHttpRequest *QueueMessageDestinationHttpRequest
}

func QueueMessageFromNATS

func QueueMessageFromNATS(msg *nats.Msg) QueueMessage

func (*QueueMessage) Bytes

func (i *QueueMessage) Bytes() []byte

func (*QueueMessage) MarshalBinary

func (i *QueueMessage) MarshalBinary() ([]byte, error)

func (*QueueMessage) NewReader

func (i *QueueMessage) NewReader() io.Reader

func (*QueueMessage) UnmarshalBinary

func (i *QueueMessage) UnmarshalBinary(data []byte) error

type QueueMessageDestinationHttpRequest

type QueueMessageDestinationHttpRequest struct {
	// The http request Method, i.e. GET, POST.
	Method string

	// 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
	Headers []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
	QueryParams string

	// 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
	Url []byte
}

func (*QueueMessageDestinationHttpRequest) Bytes

func (r *QueueMessageDestinationHttpRequest) Bytes() []byte

func (*QueueMessageDestinationHttpRequest) MarshalBinary

func (r *QueueMessageDestinationHttpRequest) MarshalBinary() ([]byte, error)

func (*QueueMessageDestinationHttpRequest) MarshalHeaders

func (r *QueueMessageDestinationHttpRequest) MarshalHeaders(headers http.Header) ([]byte, error)

func (*QueueMessageDestinationHttpRequest) MarshalQueryParams

func (r *QueueMessageDestinationHttpRequest) MarshalQueryParams(v url.Values) ([]byte, error)

func (*QueueMessageDestinationHttpRequest) MarshalUrl

func (r *QueueMessageDestinationHttpRequest) MarshalUrl(u url.URL) ([]byte, error)

func (*QueueMessageDestinationHttpRequest) SetHeaders

func (r *QueueMessageDestinationHttpRequest) SetHeaders(headers http.Header) error

func (*QueueMessageDestinationHttpRequest) SetQueryParams

func (r *QueueMessageDestinationHttpRequest) SetQueryParams(v url.Values) error

func (*QueueMessageDestinationHttpRequest) SetUrl

func (r *QueueMessageDestinationHttpRequest) SetUrl(u url.URL) error

func (*QueueMessageDestinationHttpRequest) UnmarshalBinary

func (r *QueueMessageDestinationHttpRequest) UnmarshalBinary(data []byte) error

func (*QueueMessageDestinationHttpRequest) UnmarshalHeaders

func (r *QueueMessageDestinationHttpRequest) UnmarshalHeaders() (http.Header, error)

func (*QueueMessageDestinationHttpRequest) UnmarshalQueryParams

func (r *QueueMessageDestinationHttpRequest) UnmarshalQueryParams() (url.Values, error)

func (*QueueMessageDestinationHttpRequest) UnmarshalUrl

func (r *QueueMessageDestinationHttpRequest) UnmarshalUrl() (url.URL, error)