client

Documentation

Index

• type Admin
  • func NewLocalAdmin(s *server.Server, nodeIP string, file common.ConsistentFileStore, ...) (*Admin, error)
  • func (a *Admin) Close()
  • func (a *Admin) CreateFlight(flight string, schema *codec.Schema) error
  • func (a *Admin) DeleteFlight(flight string) error
  • func (a *Admin) GetFlightSchema(flight string) (*codec.Schema, error)
  • func (a *Admin) ListFlights() map[string]*codec.Schema
  • func (a *Admin) PutFlightData(flight string, json []byte) (*codec.PutResult, error)
  • func (a *Admin) SerializeTransientColumnEntity(flight string) (uint64, []byte)
  • func (a *Admin) UpdateFlightSchema(flight string, prev uint64, schema *codec.Schema) (*codec.Schema, error)

Types

type Admin

type Admin struct {
	// contains filtered or unexported fields
}

func NewLocalAdmin

func NewLocalAdmin(
	s *server.Server,
	nodeIP string,
	file common.ConsistentFileStore,
	cluster common.ClusterInfo,
) (*Admin, error)

func (*Admin) Close

func (a *Admin) Close()

func (*Admin) CreateFlight

func (a *Admin) CreateFlight(flight string, schema *codec.Schema) error

func (*Admin) DeleteFlight

func (a *Admin) DeleteFlight(flight string) error

func (*Admin) GetFlightSchema

func (a *Admin) GetFlightSchema(flight string) (*codec.Schema, error)

func (*Admin) ListFlights

func (a *Admin) ListFlights() map[string]*codec.Schema

func (*Admin) PutFlightData

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

func (*Admin) SerializeTransientColumnEntity

func (a *Admin) SerializeTransientColumnEntity(flight string) (uint64, []byte)

func (*Admin) UpdateFlightSchema

func (a *Admin) UpdateFlightSchema(flight string, prev uint64, schema *codec.Schema) (*codec.Schema, error)

on successful, return newly updated schema upon failure, return existing schema and revision with non nil error