types

Documentation

Index

• type AppendToStreamOutput
• type AppendToStreamRequest
• type ChunkSpec
• type CreateStreamOutput
• type CreateStreamRequest
• type LiveReadInput
• type LongTermShippableFile
• type SubscribeToStreamRequest
• type SubscriberNotification
• type UnsubscribeFromStreamRequest

Types

type AppendToStreamOutput

type AppendToStreamOutput struct {
	Offset string
}

type AppendToStreamRequest

type AppendToStreamRequest struct {
	Stream string
	Lines  []string
}

type ChunkSpec

type ChunkSpec struct {
	// TODO: calculate this
	ChunkPath string `json:"chunk_path"`

	StreamName  string `json:"stream_name"`
	ChunkNumber int    `json:"chunk_number"`
}

type CreateStreamOutput

type CreateStreamOutput struct {
	Name string
}

type CreateStreamRequest

type CreateStreamRequest struct {
	Name string
}

type LiveReadInput

type LiveReadInput struct {
	Cursor         string
	MaxLinesToRead int
}

type LongTermShippableFile

type LongTermShippableFile struct {
	Block    *cursor.Cursor // offset and server irrelevant
	FilePath string
}

type SubscribeToStreamRequest

type SubscribeToStreamRequest struct {
	Stream         string
	SubscriptionId string
}

type SubscriberNotification

type SubscriberNotification struct {
	SubscriptionId         string
	LatestCursorSerialized string
}

type UnsubscribeFromStreamRequest

type UnsubscribeFromStreamRequest struct {
	Stream         string
	SubscriptionId string
}