schema

Documentation

Overview

This package is organizes the schema related use cases

In order to get started with a new schema

Index

• type Database
• type DatabaseManager
• type Server
  • func NewServer(repository WriteDatabaseRepository, manager DatabaseManager) *Server
  • func (s *Server) CreateDatabase(ctx context.Context, request *schemapb.Database) (*schemapb.CreateDatabaseResponse, error)
  • func (s *Server) DescribeDatabase(ctx context.Context, database *schemapb.Database) (*schemapb.DescribeDatabaseResponse, error)
• type WriteDatabaseRepository

Types

type Database

type Database struct {
	Name       string
	Descriptor *desc.FileDescriptor
}

type DatabaseManager

type DatabaseManager interface {
	StartDatabase(database Database)
}

type Server

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

func NewServer

func NewServer(repository WriteDatabaseRepository, manager DatabaseManager) *Server

func (*Server) CreateDatabase

func (s *Server) CreateDatabase(ctx context.Context, request *schemapb.Database) (*schemapb.CreateDatabaseResponse, error)

func (*Server) DescribeDatabase

func (s *Server) DescribeDatabase(ctx context.Context, database *schemapb.Database) (*schemapb.DescribeDatabaseResponse, error)

type WriteDatabaseRepository

type WriteDatabaseRepository interface {
	CreateDatabase(database string, fd *desc.FileDescriptor) error
}