runtime

Documentation

Index

• func BuilderFor(appCtx context.Context, cfg dubbo_cp.Config) (*core_runtime.Builder, error)
• type DummyEnvoyAdminClient
  • func (d *DummyEnvoyAdminClient) Clusters(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error)
  • func (d *DummyEnvoyAdminClient) ConfigDump(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error)
  • func (d *DummyEnvoyAdminClient) GenerateAPIToken(dp *core_mesh.DataplaneResource) (string, error)
  • func (d *DummyEnvoyAdminClient) PostQuit(ctx context.Context, dataplane *core_mesh.DataplaneResource) error
  • func (d *DummyEnvoyAdminClient) Stats(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error)
• type TestRuntimeInfo
  • func (i *TestRuntimeInfo) GetClusterId() string
  • func (i *TestRuntimeInfo) GetDeployMode() config_core.DeployMode
  • func (i *TestRuntimeInfo) GetInstanceId() string
  • func (i *TestRuntimeInfo) GetMode() config_core.CpMode
  • func (i *TestRuntimeInfo) GetStartTime() time.Time
  • func (i *TestRuntimeInfo) SetClusterId(clusterId string)

Functions

func BuilderFor

func BuilderFor(appCtx context.Context, cfg dubbo_cp.Config) (*core_runtime.Builder, error)

Types

type DummyEnvoyAdminClient

type DummyEnvoyAdminClient struct {
	PostQuitCalled   *int
	ConfigDumpCalled int
	StatsCalled      int
	ClustersCalled   int
}

func (*DummyEnvoyAdminClient) Clusters

func (d *DummyEnvoyAdminClient) Clusters(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error)

func (*DummyEnvoyAdminClient) ConfigDump

func (d *DummyEnvoyAdminClient) ConfigDump(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error)

func (*DummyEnvoyAdminClient) GenerateAPIToken

func (d *DummyEnvoyAdminClient) GenerateAPIToken(dp *core_mesh.DataplaneResource) (string, error)

func (*DummyEnvoyAdminClient) PostQuit

func (d *DummyEnvoyAdminClient) PostQuit(ctx context.Context, dataplane *core_mesh.DataplaneResource) error

func (*DummyEnvoyAdminClient) Stats

func (d *DummyEnvoyAdminClient) Stats(ctx context.Context, proxy core_model.ResourceWithAddress) ([]byte, error)

type TestRuntimeInfo

type TestRuntimeInfo struct {
	InstanceId string
	ClusterId  string
	StartTime  time.Time
	Mode       config_core.CpMode
	DeployMode config_core.DeployMode
}

func (*TestRuntimeInfo) GetClusterId

func (i *TestRuntimeInfo) GetClusterId() string

func (*TestRuntimeInfo) GetDeployMode

func (i *TestRuntimeInfo) GetDeployMode() config_core.DeployMode

func (*TestRuntimeInfo) GetInstanceId

func (i *TestRuntimeInfo) GetInstanceId() string

func (*TestRuntimeInfo) GetMode

func (i *TestRuntimeInfo) GetMode() config_core.CpMode

func (*TestRuntimeInfo) GetStartTime

func (i *TestRuntimeInfo) GetStartTime() time.Time

func (*TestRuntimeInfo) SetClusterId

func (i *TestRuntimeInfo) SetClusterId(clusterId string)