impl

Nov 8, 2023

Changes in this version

+ func Deploy(ctx context.Context, configFilename string) error

+ func NewBabysitter(ctx context.Context, app *protos.AppConfig, config *BabysitterConfig, ...) (*babysitter, error)

+ type BabysitterConfig struct

+ DeploymentId string

+ Groups map[string]string

+ Listeners map[string]int32

+ Namespace string

+ func (*BabysitterConfig) Descriptor() ([]byte, []int)

+ func (*BabysitterConfig) ProtoMessage()

+ func (x *BabysitterConfig) GetDeploymentId() string

+ func (x *BabysitterConfig) GetGroups() map[string]string

+ func (x *BabysitterConfig) GetListeners() map[string]int32

+ func (x *BabysitterConfig) GetNamespace() string

+ func (x *BabysitterConfig) ProtoReflect() protoreflect.Message

+ func (x *BabysitterConfig) Reset()

+ func (x *BabysitterConfig) String() string

+ type BabysitterOptions struct

+ HandleLogEntry func(context.Context, *protos.LogEntry) error

+ HandleMetrics func(context.Context, []*metrics.MetricSnapshot) error

+ HandleTraceSpans func(context.Context, []trace.ReadOnlySpan) error

Oct 13, 2023

Changes in this version

+ func GenerateYAMLs(image string, app *protos.AppConfig, depId string, cfg *KubeConfig) error

type ListenerOptions

+ ServiceName string

type ReplicaSetConfig

+ App *protos.AppConfig

+ Components []*ReplicaSetConfig_Component

+ DepId string

+ Name string

+ func (x *ReplicaSetConfig) GetApp() *protos.AppConfig

+ func (x *ReplicaSetConfig) GetComponents() []*ReplicaSetConfig_Component

+ func (x *ReplicaSetConfig) GetDepId() string

+ func (x *ReplicaSetConfig) GetName() string

+ type ReplicaSetConfig_Component struct

+ Listeners []*ReplicaSetConfig_Listener

+ Name string

+ func (*ReplicaSetConfig_Component) Descriptor() ([]byte, []int)

+ func (*ReplicaSetConfig_Component) ProtoMessage()

+ func (x *ReplicaSetConfig_Component) GetListeners() []*ReplicaSetConfig_Listener

+ func (x *ReplicaSetConfig_Component) GetName() string

+ func (x *ReplicaSetConfig_Component) ProtoReflect() protoreflect.Message

+ func (x *ReplicaSetConfig_Component) Reset()

+ func (x *ReplicaSetConfig_Component) String() string

type ReplicaSetConfig_Listener

+ ServiceName string

+ func (x *ReplicaSetConfig_Listener) GetServiceName() string

Sep 18, 2023

Changes in this version

+ func ToolVersion() (string, bool, error)

Sep 18, 2023

Changes in this version

type KubeConfig

+ UseHostNetwork bool

type ListenerOptions

+ Port int32

Sep 11, 2023

Changes in this version

type KubeConfig

+ LocalTag string

+ Repo string

Aug 11, 2023

Changes in this version

type KubeConfig

+ Namespace string

+ Observability map[string]string

type ReplicaSetConfig

+ Namespace string

+ TraceServiceUrl string

+ func (x *ReplicaSetConfig) GetNamespace() string

+ func (x *ReplicaSetConfig) GetTraceServiceUrl() string

Jul 11, 2023

Changes in this version

type KubeConfig

+ Image string

Jun 14, 2023

Changes in this version

+ var File_internal_impl_kube_proto protoreflect.FileDescriptor

+ func BuildAndUploadDockerImage(ctx context.Context, dep *protos.Deployment) (string, error)

+ func GenerateKubeDeployment(image string, dep *protos.Deployment, cfg *KubeConfig) error

+ func RunBabysitter(ctx context.Context) error

+ type KubeConfig struct

+ Listeners map[string]*ListenerOptions

+ type ListenerOptions struct

+ Public bool

+ type ReplicaSetConfig struct

+ ComponentsToStart map[string]*ReplicaSetConfig_Listeners

+ Deployment *protos.Deployment

+ InternalPort int32

+ ReplicaSet string

+ func (*ReplicaSetConfig) Descriptor() ([]byte, []int)

+ func (*ReplicaSetConfig) ProtoMessage()

+ func (x *ReplicaSetConfig) GetComponentsToStart() map[string]*ReplicaSetConfig_Listeners

+ func (x *ReplicaSetConfig) GetDeployment() *protos.Deployment

+ func (x *ReplicaSetConfig) GetInternalPort() int32

+ func (x *ReplicaSetConfig) GetReplicaSet() string

+ func (x *ReplicaSetConfig) ProtoReflect() protoreflect.Message

+ func (x *ReplicaSetConfig) Reset()

+ func (x *ReplicaSetConfig) String() string

+ type ReplicaSetConfig_Listener struct

+ ExternalPort int32

+ IsPublic bool

+ Name string

+ func (*ReplicaSetConfig_Listener) Descriptor() ([]byte, []int)

+ func (*ReplicaSetConfig_Listener) ProtoMessage()

+ func (x *ReplicaSetConfig_Listener) GetExternalPort() int32

+ func (x *ReplicaSetConfig_Listener) GetIsPublic() bool

+ func (x *ReplicaSetConfig_Listener) GetName() string

+ func (x *ReplicaSetConfig_Listener) ProtoReflect() protoreflect.Message

+ func (x *ReplicaSetConfig_Listener) Reset()

+ func (x *ReplicaSetConfig_Listener) String() string

+ type ReplicaSetConfig_Listeners struct

+ Listeners []*ReplicaSetConfig_Listener

+ func (*ReplicaSetConfig_Listeners) Descriptor() ([]byte, []int)

+ func (*ReplicaSetConfig_Listeners) ProtoMessage()

+ func (x *ReplicaSetConfig_Listeners) GetListeners() []*ReplicaSetConfig_Listener

+ func (x *ReplicaSetConfig_Listeners) ProtoReflect() protoreflect.Message

+ func (x *ReplicaSetConfig_Listeners) Reset()

+ func (x *ReplicaSetConfig_Listeners) String() string