Skip to content

Commit

Permalink
remove unused status method in patroni
Browse files Browse the repository at this point in the history
  • Loading branch information
mkabilov committed Oct 16, 2017
1 parent 757515a commit a3fe28d
Showing 1 changed file with 1 addition and 57 deletions.
58 changes: 1 addition & 57 deletions pkg/util/patroni/patroni.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@ const (
// Interface describe patroni methods
type Interface interface {
Failover(master *v1.Pod, candidate string) error
Status(pod *v1.Pod) (*Status, error)
}

// Patroni API client
Expand All @@ -30,39 +29,6 @@ type Patroni struct {
logger *logrus.Entry
}

//XlogSpec...
type XlogSpec struct {
Location uint64 `json:"location"`
}

//ReplicationSpec describes replication specific parameters
type ReplicationSpec struct {
State string `json:"state"`
SyncPriority uint `json:"sync_priority"`
SyncState string `json:"sync_state"`
Usename string `json:"usename"`
ApplicationName string `json:"application_name"`
ClientAddr string `json:"client_addr"`
}

// PatroniSpec describes patroni specific parameters
type PatroniSpec struct {
Scope string `json:"scope"`
Version string `json:"version"`
}

// Status describes status returned by patroni API
type Status struct {
State string `json:"state"`
Xlog XlogSpec `json:"xlog"`
ServerVersion uint64 `json:"server_version"`
Role string `json:"role"`
Replication []ReplicationSpec `json:"replication"`
DatabaseSystemIdentifier string `json:"database_system_identifier"`
PostmasterStartTime string `json:"postmaster_start_time"`
Patroni PatroniSpec `json:"patroni"`
}

// New create patroni
func New(logger *logrus.Entry) *Patroni {
cl := http.Client{
Expand Down Expand Up @@ -111,26 +77,4 @@ func (p *Patroni) Failover(master *v1.Pod, candidate string) error {
}

return nil
}

// Status returns patroni status
func (p *Patroni) Status(pod *v1.Pod) (*Status, error) {
status := &Status{}

request, err := http.NewRequest(http.MethodGet, apiURL(pod), nil)
if err != nil {
return nil, fmt.Errorf("could not make new request: %v", err)
}

resp, err := http.DefaultClient.Do(request)
if err != nil {
return nil, fmt.Errorf("could not make request: %v", err)
}

err = json.NewDecoder(resp.Body).Decode(status)
if err != nil {
return nil, fmt.Errorf("could not parse response from patroni: %v", err)
}

return status, nil
}
}

0 comments on commit a3fe28d

Please sign in to comment.