test

Documentation

Index

• Variables
• func LoopbackIPs() []string
• func RunBasicJetStreamServer(ith int, ip string, routes []*url.URL) *server.Server
• type InMemoryFlightActionHandler
  • func NewInMemoryFlightActionHandler() *InMemoryFlightActionHandler
  • func (n *InMemoryFlightActionHandler) CreateFlight(flight string, schema *codec.Schema) error
  • func (n *InMemoryFlightActionHandler) DeleteFlight(flight string) error
  • func (n *InMemoryFlightActionHandler) GetFlightSchema(flight string) (*codec.Schema, error)
  • func (n *InMemoryFlightActionHandler) ListFlights() map[string]*codec.Schema
  • func (n *InMemoryFlightActionHandler) PutFlightData(flight string, json []byte) (*codec.PutResult, error)
  • func (n *InMemoryFlightActionHandler) SerializeTransientColumnEntity(flight string) (uint64, []byte)
  • func (n *InMemoryFlightActionHandler) SetTransientColumnEntity(id uint64, data []byte)
  • func (n *InMemoryFlightActionHandler) UpdateFlightSchema(flight string, _ uint64, schema *codec.Schema) (*codec.Schema, error)
• type JSClusters
  • func RunClusterJetStreamServer(ips []string) *JSClusters
  • func (jsc *JSClusters) GetHostsAndLocal() ([]string, int)
  • func (jsc *JSClusters) Shutdown()
• type NoOpFileHandler
  • func (n *NoOpFileHandler) BaseDir() string
  • func (n *NoOpFileHandler) OnUpload(req *codec.FileTransferRequest) error
  • func (n *NoOpFileHandler) PrepareFlight(flight string) error
  • func (n *NoOpFileHandler) RemoveFlight(flight string) error
  • func (n *NoOpFileHandler) RemoveLocal(flight string, fid uint64) error
  • func (n *NoOpFileHandler) SaveLocal(flight string, fid uint64, data []byte) error
  • func (n *NoOpFileHandler) Stop()
  • func (n *NoOpFileHandler) UploadToStore(flight string, fid uint64, data []byte, ips []string) []error

Variables

var FlightPort string

Functions

func LoopbackIPs

func LoopbackIPs() []string

func RunBasicJetStreamServer

func RunBasicJetStreamServer(ith int, ip string, routes []*url.URL) *server.Server

Types

type InMemoryFlightActionHandler

type InMemoryFlightActionHandler struct {
	TransientID     uint64
	TransientEntity []byte
	// contains filtered or unexported fields
}

func NewInMemoryFlightActionHandler

func NewInMemoryFlightActionHandler() *InMemoryFlightActionHandler

func (*InMemoryFlightActionHandler) CreateFlight

func (n *InMemoryFlightActionHandler) CreateFlight(flight string, schema *codec.Schema) error

func (*InMemoryFlightActionHandler) DeleteFlight

func (n *InMemoryFlightActionHandler) DeleteFlight(flight string) error

func (*InMemoryFlightActionHandler) GetFlightSchema

func (n *InMemoryFlightActionHandler) GetFlightSchema(flight string) (*codec.Schema, error)

func (*InMemoryFlightActionHandler) ListFlights

func (n *InMemoryFlightActionHandler) ListFlights() map[string]*codec.Schema

func (*InMemoryFlightActionHandler) PutFlightData

func (n *InMemoryFlightActionHandler) PutFlightData(flight string, json []byte) (*codec.PutResult, error)

func (*InMemoryFlightActionHandler) SerializeTransientColumnEntity

func (n *InMemoryFlightActionHandler) SerializeTransientColumnEntity(flight string) (uint64, []byte)

func (*InMemoryFlightActionHandler) SetTransientColumnEntity

func (n *InMemoryFlightActionHandler) SetTransientColumnEntity(id uint64, data []byte)

func (*InMemoryFlightActionHandler) UpdateFlightSchema

func (n *InMemoryFlightActionHandler) UpdateFlightSchema(flight string, _ uint64, schema *codec.Schema) (*codec.Schema, error)

type JSClusters

type JSClusters struct {
	Servers []*server.Server
	IPS     []string
	Local   int
}

func RunClusterJetStreamServer

func RunClusterJetStreamServer(ips []string) *JSClusters

func (*JSClusters) GetHostsAndLocal

func (jsc *JSClusters) GetHostsAndLocal() ([]string, int)

func (*JSClusters) Shutdown

func (jsc *JSClusters) Shutdown()

type NoOpFileHandler

type NoOpFileHandler struct {
}

func (*NoOpFileHandler) BaseDir

func (n *NoOpFileHandler) BaseDir() string

func (*NoOpFileHandler) OnUpload

func (n *NoOpFileHandler) OnUpload(req *codec.FileTransferRequest) error

func (*NoOpFileHandler) PrepareFlight

func (n *NoOpFileHandler) PrepareFlight(flight string) error

func (*NoOpFileHandler) RemoveFlight

func (n *NoOpFileHandler) RemoveFlight(flight string) error

func (*NoOpFileHandler) RemoveLocal

func (n *NoOpFileHandler) RemoveLocal(flight string, fid uint64) error

func (*NoOpFileHandler) SaveLocal

func (n *NoOpFileHandler) SaveLocal(flight string, fid uint64, data []byte) error

func (*NoOpFileHandler) Stop

func (n *NoOpFileHandler) Stop()

func (*NoOpFileHandler) UploadToStore

func (n *NoOpFileHandler) UploadToStore(flight string, fid uint64, data []byte, ips []string) []error