Documentation
¶
Index ¶
Constants ¶
View Source
const ( CodeSuccess = "success" CodeIncorrectBaseOffset = "incorrect_base_offset" CodeIncorrectSubscriptionId = "incorrect_subscription_id" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PushInput ¶
type PushInput struct {
SubscriptionId string
Push *rtypes.ReadResult
}
func NewPushInput ¶
func NewPushInput(subscriptionId string, readResult *rtypes.ReadResult) *PushInput
type PushOutput ¶
type PushOutput struct {
Code string
AcceptedOffset string
CorrectSubscriptionId string `json:",omitempty"`
BehindCursors []string
}
func NewPushOutputIncorrectBaseOffset ¶
func NewPushOutputIncorrectBaseOffset(correctBaseOffset string) *PushOutput
func NewPushOutputIncorrectSubscriptionId ¶
func NewPushOutputIncorrectSubscriptionId(correctSubscriptionId string) *PushOutput
func NewPushOutputSuccess ¶
func NewPushOutputSuccess(acceptedOffset string, behindCursors []string) *PushOutput
type Transport ¶
type Transport interface {
Push(*PushInput) (*PushOutput, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.