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

	metastorev1.IndexServiceClient
	metastorev1.CompactionServiceClient
	metastorev1.MetadataQueryServiceClient
	metastorev1.TenantServiceClient
	raftnodepb.RaftNodeServiceClient
}

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()