m3db

Feb 16, 2021

Changes in this version

+ func GenerateStatefulSetNodeAffinity(isoGroup myspec.IsolationGroup) (*v1.NodeAffinity, error)

+ func GenerateStatefulSetPodAntiAffinity(isoGroup myspec.IsolationGroup) (*v1.PodAntiAffinity, error)

Feb 13, 2020

Changes in this version

+ const PortM3Coordinator

+ const PortM3CoordinatorCarbon

+ const PortM3CoordinatorMetrics

+ const PortM3DBDebug

+ const PortM3DBHTTPCluster

+ const PortM3DBHTTPNode

+ const PortM3DBNodeClient

+ const PortM3DBNodeCluster

+ func CoordinatorServiceName(clusterName string) string

+ func GenerateCRD(enableValidation bool) *apiextensionsv1beta1.CustomResourceDefinition

+ func GenerateCoordinatorService(cluster *myspec.M3DBCluster) (*v1.Service, error)

+ func GenerateDefaultConfigMap(cluster *myspec.M3DBCluster) (*corev1.ConfigMap, error)

+ func GenerateM3DBService(cluster *myspec.M3DBCluster) (*v1.Service, error)

+ func GenerateOwnerRef(cluster *myspec.M3DBCluster) *metav1.OwnerReference

+ func GenerateStatefulSet(cluster *myspec.M3DBCluster, isolationGroupName string, instanceAmount int32) (*appsv1.StatefulSet, error)

+ func GenerateStatefulSetAffinity(isoGroup myspec.IsolationGroup) (*v1.Affinity, error)

+ func HeadlessServiceName(clusterName string) string

+ func NewBaseStatefulSet(ssName, isolationGroup string, cluster *myspec.M3DBCluster, ...) *appsv1.StatefulSet

+ func PlacementInstanceFromPod(cluster *myspec.M3DBCluster, pod *corev1.Pod, idProvider podidentity.Provider) (*placementpb.Instance, error)

+ func StatefulSetName(clusterName string, stsID int) string

+ type K8sops interface

+ CreateOrUpdateCRD func(name string, enableValidation bool) error

+ DeleteService func(cluster *myspec.M3DBCluster, name string) error

+ EnsureService func(cluster *myspec.M3DBCluster, svc *v1.Service) error

+ Events func(namespace string) typedcorev1.EventInterface

+ GetService func(cluster *myspec.M3DBCluster, name string) (*v1.Service, error)

+ func New(opts ...Option) (K8sops, error)

+ type MockK8sops struct

+ func NewMockK8sops(ctrl *gomock.Controller) *MockK8sops

+ func (m *MockK8sops) CreateOrUpdateCRD(name string, enableValidation bool) error

+ func (m *MockK8sops) DeleteService(cluster *v1alpha1.M3DBCluster, name string) error

+ func (m *MockK8sops) EXPECT() *MockK8sopsMockRecorder

+ func (m *MockK8sops) EnsureService(cluster *v1alpha1.M3DBCluster, svc *v1.Service) error

+ func (m *MockK8sops) Events(namespace string) v10.EventInterface

+ func (m *MockK8sops) GetService(cluster *v1alpha1.M3DBCluster, name string) (*v1.Service, error)

+ type MockK8sopsMockRecorder struct

+ func (mr *MockK8sopsMockRecorder) CreateOrUpdateCRD(name, enableValidation interface{}) *gomock.Call

+ func (mr *MockK8sopsMockRecorder) DeleteService(cluster, name interface{}) *gomock.Call

+ func (mr *MockK8sopsMockRecorder) EnsureService(cluster, svc interface{}) *gomock.Call

+ func (mr *MockK8sopsMockRecorder) Events(namespace interface{}) *gomock.Call

+ func (mr *MockK8sopsMockRecorder) GetService(cluster, name interface{}) *gomock.Call

+ type Option interface

+ func WithCRDClient(crdClient genclient.Interface) Option

+ func WithExtClient(extClient apiextensionsclient.Interface) Option

+ func WithKClient(kclient kubernetes.Interface) Option

+ func WithLogger(logger *zap.Logger) Option

+ type Port int32