Method UnmarshalJSON

state_tracker.go:67–90

(data []byte)

}

func (s *SerializableState) UnmarshalJSON(data []byte) error {
	type Alias SerializableState
	aux := &struct {
		LastSuccessfulPaginationKeys map[string]json.RawMessage
		*Alias
	}{
		Alias: (*Alias)(s),
	}

	if err := json.Unmarshal(data, &aux); err != nil {
		return err
	}

	s.LastSuccessfulPaginationKeys = make(map[string]PaginationKey)
	for k, v := range aux.LastSuccessfulPaginationKeys {
		pk, err := UnmarshalPaginationKey(v)
		if err != nil {
			return err
		}
		s.LastSuccessfulPaginationKeys[k] = pk
	}

	return nil
}

func (s *SerializableState) MinSourceBinlogPosition() mysql.Position {
	nilPosition := mysql.Position{}