Versions in this module Expand all Collapse all v0 v0.24.0 Jul 15, 2025 Changes in this version + var File_internal_tool_ssh_impl_ssh_proto protoreflect.FileDescriptor + var LogDir = filepath.Join(runtime.LogsDir(), "ssh") + var PerfettoFile = filepath.Join(dataDir, "traces.DB") + func DefaultRegistry(ctx context.Context) (*status.Registry, error) + func RunBabysitter(ctx context.Context) error + func RunManager(ctx context.Context, config *SshConfig, locations map[string]string) (func() error, error) + type BabysitterInfo struct + App *protos.AppConfig + DepId string + Group string + LogDir string + ManagerAddr string + ReplicaId int32 + RunMain bool + func (*BabysitterInfo) Descriptor() ([]byte, []int) + func (*BabysitterInfo) ProtoMessage() + func (x *BabysitterInfo) GetApp() *protos.AppConfig + func (x *BabysitterInfo) GetDepId() string + func (x *BabysitterInfo) GetGroup() string + func (x *BabysitterInfo) GetLogDir() string + func (x *BabysitterInfo) GetManagerAddr() string + func (x *BabysitterInfo) GetReplicaId() int32 + func (x *BabysitterInfo) GetRunMain() bool + func (x *BabysitterInfo) ProtoReflect() protoreflect.Message + func (x *BabysitterInfo) Reset() + func (x *BabysitterInfo) String() string + type BabysitterMetrics struct + GroupName string + Metrics []*protos.MetricSnapshot + ReplicaId int32 + func (*BabysitterMetrics) Descriptor() ([]byte, []int) + func (*BabysitterMetrics) ProtoMessage() + func (x *BabysitterMetrics) GetGroupName() string + func (x *BabysitterMetrics) GetMetrics() []*protos.MetricSnapshot + func (x *BabysitterMetrics) GetReplicaId() int32 + func (x *BabysitterMetrics) ProtoReflect() protoreflect.Message + func (x *BabysitterMetrics) Reset() + func (x *BabysitterMetrics) String() string + type GetComponentsReply struct + Components []string + Version string + func (*GetComponentsReply) Descriptor() ([]byte, []int) + func (*GetComponentsReply) ProtoMessage() + func (x *GetComponentsReply) GetComponents() []string + func (x *GetComponentsReply) GetVersion() string + func (x *GetComponentsReply) ProtoReflect() protoreflect.Message + func (x *GetComponentsReply) Reset() + func (x *GetComponentsReply) String() string + type GetComponentsRequest struct + Group string + Version string + func (*GetComponentsRequest) Descriptor() ([]byte, []int) + func (*GetComponentsRequest) ProtoMessage() + func (x *GetComponentsRequest) GetGroup() string + func (x *GetComponentsRequest) GetVersion() string + func (x *GetComponentsRequest) ProtoReflect() protoreflect.Message + func (x *GetComponentsRequest) Reset() + func (x *GetComponentsRequest) String() string + type GetRoutingInfoReply struct + RoutingInfo *protos.RoutingInfo + Version string + func (*GetRoutingInfoReply) Descriptor() ([]byte, []int) + func (*GetRoutingInfoReply) ProtoMessage() + func (x *GetRoutingInfoReply) GetRoutingInfo() *protos.RoutingInfo + func (x *GetRoutingInfoReply) GetVersion() string + func (x *GetRoutingInfoReply) ProtoReflect() protoreflect.Message + func (x *GetRoutingInfoReply) Reset() + func (x *GetRoutingInfoReply) String() string + type GetRoutingInfoRequest struct + Component string + RequestingGroup string + Routed bool + Version string + func (*GetRoutingInfoRequest) Descriptor() ([]byte, []int) + func (*GetRoutingInfoRequest) ProtoMessage() + func (x *GetRoutingInfoRequest) GetComponent() string + func (x *GetRoutingInfoRequest) GetRequestingGroup() string + func (x *GetRoutingInfoRequest) GetRouted() bool + func (x *GetRoutingInfoRequest) GetVersion() string + func (x *GetRoutingInfoRequest) ProtoReflect() protoreflect.Message + func (x *GetRoutingInfoRequest) Reset() + func (x *GetRoutingInfoRequest) String() string + type ReplicaToRegister struct + Address string + Group string + Pid int64 + WeaveletId string + func (*ReplicaToRegister) Descriptor() ([]byte, []int) + func (*ReplicaToRegister) ProtoMessage() + func (x *ReplicaToRegister) GetAddress() string + func (x *ReplicaToRegister) GetGroup() string + func (x *ReplicaToRegister) GetPid() int64 + func (x *ReplicaToRegister) GetWeaveletId() string + func (x *ReplicaToRegister) ProtoReflect() protoreflect.Message + func (x *ReplicaToRegister) Reset() + func (x *ReplicaToRegister) String() string + type SshConfig struct + App *protos.AppConfig + DepId string + Listeners map[string]*SshConfig_ListenerOptions + Locations string + func (*SshConfig) Descriptor() ([]byte, []int) + func (*SshConfig) ProtoMessage() + func (x *SshConfig) GetApp() *protos.AppConfig + func (x *SshConfig) GetDepId() string + func (x *SshConfig) GetListeners() map[string]*SshConfig_ListenerOptions + func (x *SshConfig) GetLocations() string + func (x *SshConfig) ProtoReflect() protoreflect.Message + func (x *SshConfig) Reset() + func (x *SshConfig) String() string + type SshConfig_ListenerOptions struct + Address string + func (*SshConfig_ListenerOptions) Descriptor() ([]byte, []int) + func (*SshConfig_ListenerOptions) ProtoMessage() + func (x *SshConfig_ListenerOptions) GetAddress() string + func (x *SshConfig_ListenerOptions) ProtoReflect() protoreflect.Message + func (x *SshConfig_ListenerOptions) Reset() + func (x *SshConfig_ListenerOptions) String() string