types

Documentation

Index

• Constants
• type PushInput
  • func NewPushInput(subscriptionId string, readResult *rtypes.ReadResult) *PushInput
• type PushOutput
  • func NewPushOutputIncorrectBaseOffset(correctBaseOffset string) *PushOutput
  • func NewPushOutputIncorrectSubscriptionId(correctSubscriptionId string) *PushOutput
  • func NewPushOutputSuccess(acceptedOffset string, behindCursors []string) *PushOutput
• type Transport

Constants

const (
	CodeSuccess                 = "success"
	CodeIncorrectBaseOffset     = "incorrect_base_offset"
	CodeIncorrectSubscriptionId = "incorrect_subscription_id"
)

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)
}