control

Documentation

Index

• Constants
• type AkasaletControl
• type DeployerControl

Constants

const (
	AkasaletPath = "github.com/kanengo/akasar/akasaletControl"
)

const DeployerPath = "github.com/kanengo/akasar/deployerControl"

Types

type AkasaletControl

type AkasaletControl interface {
	// InitAkasalet 初始化akasalet
	InitAkasalet(context.Context, *protos.InitAkasaletRequest) (*protos.InitAkasaletReply, error)

	// UpdateComponents 更新 akasalet 应该运行的最新组件set
	UpdateComponents(context.Context, *protos.UpdateComponentsRequest) (*protos.UpdateComponentsReply, error)

	// UpdateRoutingInfo 为akasalet更新一个组件的最新路由信息
	UpdateRoutingInfo(context.Context, *protos.UpdateRoutingInfoRequest) (*protos.UpdateRoutingInfoReply, error)

	// GetHealth 获取健康信息
	GetHealth(context.Context, *protos.GetHealthRequest) (*protos.GetHealthReply, error)

	// GetLoad 获取 akasalet 负荷信息
	GetLoad(context.Context, *protos.GetLoadRequest) (*protos.GetLoadReply, error)

	// GetMetrics 获取 akasalet 指标信息
	GetMetrics(context.Context, *protos.GetMetricsRequest) (*protos.GetMetricsReply, error)

	// GetProfile 获取 akasalet profile
	GetProfile(context.Context, *protos.GetProfileRequest) (*protos.GetProfileReply, error)
}

type DeployerControl

type DeployerControl interface {
	// LogBatch 批量记录日志
	LogBatch(context.Context, *protos.LogEntryBatch) error

	// HandlerTraceSpans 处理链路追踪spans
	HandlerTraceSpans(context.Context, *protos.TraceSpans) error

	// ActivateComponent 激活组件
	// 一次ActivateComponent的调用会立即通知对应的akasalet组件的路由信息
	ActivateComponent(context.Context, *protos.ActivateComponentRequest) (*protos.ActivateComponentReply, error)

	// GetListenerAddress 返回akasalet应该监听的地址
	GetListenerAddress(context.Context, *protos.GetListenerAddressRequest) (*protos.GetListenerAddressReply, error)

	// ExportListener 导出 akasalet 的 listener, deployer会代理这些listener
	ExportListener(context.Context, *protos.ExportListenerRequest) (*protos.ExportListenerReply, error)
}