storage

Documentation

Index

• type GetLatestStreamPostitionRequest
• type GetLatestStreamPostitionResponse
• type ICentrifugeInputStorage
• type StoreStreamPostitionRequest
• type StoreStreamPostitionResponse

Types

type GetLatestStreamPostitionRequest

type GetLatestStreamPostitionRequest struct{}

type GetLatestStreamPostitionResponse

type GetLatestStreamPostitionResponse struct {
	StreamPosition *centrifuge.StreamPosition
}

type ICentrifugeInputStorage

type ICentrifugeInputStorage interface {
	StoreStreamPostition(request *StoreStreamPostitionRequest) (*StoreStreamPostitionResponse, error)
	GetLatestStreamPostition(request *GetLatestStreamPostitionRequest) (*GetLatestStreamPostitionResponse, error)
}

ICentrifugeInputStorage ...

type StoreStreamPostitionRequest

type StoreStreamPostitionRequest struct {
	StreamPosition *centrifuge.StreamPosition
}

type StoreStreamPostitionResponse

type StoreStreamPostitionResponse struct{}