scheme

Documentation

Index

• type Client
• type Directory
• type Entry
  • func InnerConvertEntry(y *Ydb_Scheme.Entry) *Entry
  • func (e *Entry) IsBlockStoreVolume() bool
  • func (e *Entry) IsCoordinationNode() bool
  • func (e *Entry) IsDatabase() bool
  • func (e *Entry) IsDirectory() bool
  • func (e *Entry) IsPersQueueGroup() bool
  • func (e *Entry) IsRtmrVolume() bool
  • func (e *Entry) IsTable() bool
• type EntryType
  • func (t EntryType) String() string
• type Permissions
• type PermissionsOption
  • func WithChangeOwner(owner string) PermissionsOption
  • func WithClearPermissions() PermissionsOption
  • func WithGrantPermissions(p Permissions) PermissionsOption
  • func WithRevokePermissions(p Permissions) PermissionsOption
  • func WithSetPermissions(p Permissions) PermissionsOption
• type Scheme
  • func New(c cluster.Cluster) Scheme

Types

type Client

type Client interface {
	Scheme

	CleanupDatabase(ctx context.Context, prefix string, names ...string) error
	EnsurePathExists(ctx context.Context, path string) error
}

type Directory

type Directory struct {
	Entry
	Children []Entry
}

type Entry

type Entry struct {
	Name                 string
	Owner                string
	Type                 EntryType
	Permissions          []Permissions
	EffectivePermissions []Permissions
}

func InnerConvertEntry

func InnerConvertEntry(y *Ydb_Scheme.Entry) *Entry

func (*Entry) IsBlockStoreVolume

func (e *Entry) IsBlockStoreVolume() bool

func (*Entry) IsCoordinationNode

func (e *Entry) IsCoordinationNode() bool

func (*Entry) IsDatabase

func (e *Entry) IsDatabase() bool

func (*Entry) IsDirectory

func (e *Entry) IsDirectory() bool

func (*Entry) IsPersQueueGroup

func (e *Entry) IsPersQueueGroup() bool

func (*Entry) IsRtmrVolume

func (e *Entry) IsRtmrVolume() bool

func (*Entry) IsTable

func (e *Entry) IsTable() bool

type EntryType

type EntryType uint

const (
	EntryTypeUnknown EntryType = iota
	EntryDirectory
	EntryTable
	EntryPersQueueGroup
	EntryDatabase
	EntryRtmrVolume
	EntryBlockStoreVolume
	EntryCoordinationNode
)

func (EntryType) String

func (t EntryType) String() string

type Permissions

type Permissions struct {
	Subject         string
	PermissionNames []string
}

type PermissionsOption

type PermissionsOption func(*permissionsDesc)

func WithChangeOwner

func WithChangeOwner(owner string) PermissionsOption

func WithClearPermissions

func WithClearPermissions() PermissionsOption

func WithGrantPermissions

func WithGrantPermissions(p Permissions) PermissionsOption

func WithRevokePermissions

func WithRevokePermissions(p Permissions) PermissionsOption

func WithSetPermissions

func WithSetPermissions(p Permissions) PermissionsOption

type Scheme

type Scheme interface {
	DescribePath(ctx context.Context, path string) (e Entry, err error)
	MakeDirectory(ctx context.Context, path string) (err error)
	ListDirectory(ctx context.Context, path string) (d Directory, err error)
	RemoveDirectory(ctx context.Context, path string) (err error)

	Close(ctx context.Context) error
}

func New

func New(c cluster.Cluster) Scheme