test

Documentation

Index

• func MockStaticDiscovery(t *testing.T, servers []discovery.Server) *mockdiscovery.MockDiscovery
• type MetastoreInstance
• type MetastoreSet
  • func NewMetastoreSet(t *testing.T, cfg *metastore.Config, n int, bucket objstore.Bucket) MetastoreSet
  • func (m *MetastoreSet) Close()

Functions

func MockStaticDiscovery

func MockStaticDiscovery(t *testing.T, servers []discovery.Server) *mockdiscovery.MockDiscovery

Types

type MetastoreInstance

type MetastoreInstance struct {
	Metastore               *metastore.Metastore
	Server                  *grpc.Server
	Connection              *grpc.ClientConn
	MetastoreInstanceClient metastorev1.MetastoreServiceClient
	CompactorInstanceClient compactorv1.CompactionPlannerClient
}

type MetastoreSet

type MetastoreSet struct {
	Instances []MetastoreInstance
	Client    *metastoreclient.Client
	// contains filtered or unexported fields
}

func NewMetastoreSet

func NewMetastoreSet(t *testing.T, cfg *metastore.Config, n int, bucket objstore.Bucket) MetastoreSet

func (*MetastoreSet) Close

func (m *MetastoreSet) Close()