httphelper

Nov 23, 2020

Changes in this version

+ const WgetNodeDrainEndpoint

+ func GetMgmtApiWgetAction(dc *api.CassandraDatacenter, endpoint string) (*corev1.ExecAction, error)

+ func GetMgmtApiWgetPostAction(dc *api.CassandraDatacenter, endpoint string, postData string) (*corev1.ExecAction, error)

type EndpointState

+ Load string

+ Status string

type InsecureManagementApiSecurityProvider

+ func (provider *InsecureManagementApiSecurityProvider) BuildMgmtApiWgetAction(endpoint string) *corev1.ExecAction

+ func (provider *InsecureManagementApiSecurityProvider) BuildMgmtApiWgetPostAction(endpoint string, postData string) *corev1.ExecAction

type ManagementApiSecurityProvider

+ BuildMgmtApiWgetAction func(endpoint string) *corev1.ExecAction

+ BuildMgmtApiWgetPostAction func(endpoint string, postData string) *corev1.ExecAction

type ManualManagementApiSecurityProvider

+ func (provider *ManualManagementApiSecurityProvider) BuildMgmtApiWgetAction(endpoint string) *corev1.ExecAction

+ func (provider *ManualManagementApiSecurityProvider) BuildMgmtApiWgetPostAction(endpoint string, postData string) *corev1.ExecAction

type NodeMgmtClient

+ func (client *NodeMgmtClient) CallDecommissionNodeEndpoint(pod *corev1.Pod) error

Jun 30, 2020

Changes in this version

+ type NoPodIPError error

May 29, 2020

Changes in this version

+ func AddManagementApiServerSecurity(dc *api.CassandraDatacenter, pod *corev1.PodTemplateSpec) error

+ func BuildPodHostFromPod(pod *corev1.Pod) string

+ func GetManagementApiProtocol(dc *api.CassandraDatacenter) (string, error)

+ func GetPodHost(podName, clusterName, dcName, namespace string) string

+ func ValidateManagementApiConfig(dc *api.CassandraDatacenter, client client.Client, ctx context.Context) []error

+ type CassMetadataEndpoints struct

+ Entity []EndpointState

+ type EndpointState struct

+ HostID string

+ IsAlive string

+ NativeTransportAddress string

+ RpcAddress string

+ func (x *EndpointState) GetRpcAddress() string

+ type HttpClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ func BuildManagementApiHttpClient(dc *api.CassandraDatacenter, client client.Client, ctx context.Context) (HttpClient, error)

+ type InsecureManagementApiSecurityProvider struct

+ func (provider *InsecureManagementApiSecurityProvider) AddServerSecurity(pod *corev1.PodTemplateSpec) error

+ func (provider *InsecureManagementApiSecurityProvider) BuildHttpClient(client client.Client, ctx context.Context) (HttpClient, error)

+ func (provider *InsecureManagementApiSecurityProvider) GetProtocol() string

+ func (provider *InsecureManagementApiSecurityProvider) ValidateConfig(client client.Client, ctx context.Context) []error

+ type ManagementApiSecurityProvider interface

+ AddServerSecurity func(pod *corev1.PodTemplateSpec) error

+ BuildHttpClient func(client client.Client, ctx context.Context) (HttpClient, error)

+ GetProtocol func() string

+ ValidateConfig func(client client.Client, ctx context.Context) []error

+ func BuildManagmenetApiSecurityProvider(dc *api.CassandraDatacenter) (ManagementApiSecurityProvider, error)

+ type ManualManagementApiSecurityProvider struct

+ Config *api.ManagementApiAuthManualConfig

+ Namespace string

+ func (provider *ManualManagementApiSecurityProvider) AddServerSecurity(pod *corev1.PodTemplateSpec) error

+ func (provider *ManualManagementApiSecurityProvider) BuildHttpClient(client client.Client, ctx context.Context) (HttpClient, error)

+ func (provider *ManualManagementApiSecurityProvider) GetProtocol() string

+ func (provider *ManualManagementApiSecurityProvider) ValidateConfig(client client.Client, ctx context.Context) []error

+ type NodeMgmtClient struct

+ Client HttpClient

+ Log logr.Logger

+ Protocol string

+ func (client *NodeMgmtClient) CallCreateRoleEndpoint(pod *corev1.Pod, username string, password string) error

+ func (client *NodeMgmtClient) CallDrainEndpoint(pod *corev1.Pod) error

+ func (client *NodeMgmtClient) CallKeyspaceCleanupEndpoint(pod *corev1.Pod, jobs int, keyspaceName string, tables []string) error

+ func (client *NodeMgmtClient) CallLifecycleStartEndpoint(pod *corev1.Pod) error

+ func (client *NodeMgmtClient) CallLifecycleStartEndpointWithReplaceIp(pod *corev1.Pod, replaceIp string) error

+ func (client *NodeMgmtClient) CallMetadataEndpointsEndpoint(pod *corev1.Pod) (CassMetadataEndpoints, error)

+ func (client *NodeMgmtClient) CallProbeClusterEndpoint(pod *corev1.Pod, consistencyLevel string, rfPerDc int) error

+ func (client *NodeMgmtClient) CallReloadSeedsEndpoint(pod *corev1.Pod) error